何时在 Flink 中使用临时 table 或永久 table

when to use Temporary table or permanent table in Flink

Flink 新手,我正在构建一个简单的聚合管道,例如每天的销售额。我正在使用 table api。我看到创建 table 有两个选项:临时和永久。对于永久 table,我们还需要设置一个目录,例如蜂巢。所以我倾向于使用临时的table,这样容易上手。不过很好奇彼此的好与坏。

根据文档,当 Flink 作业停止时,临时 table 不会继续存在。那如果我们为了bug修复做一个Flink Job部署会怎么样呢

谢谢!

A table 不存储您的数据,而是存储元数据,即 table 的名称和位置。例如,在 table 由 Kafka 支持的情况下,经纪人的地址和主题名称。

用临时的table就可以了。但如果你想与其他应用程序共享此元数据,那么将其存储在目录中并使用永久 tables.

会很方便