如何在 Flink 的 SQL CLI 中保存查询结果

Question

我正在使用 Flink SQL CLI 运行 SQL 查询， 我需要保存“SELECT ...NOW()...FROM ...”等查询的结果 其中包括时间戳。 我想在评估 NOW() 时保留时间戳，而不触发重新评估。 如何仅使用 SQL CLI 将结果的副本保存在本地文件中？

我尝试着奔跑

INSERT INTO tableTwo select ... , Now(), ... from tableOne

但是从 flink Web 监视器中，我发现该查询的作业永远不会执行完毕。我想知道是否还有另一种方法可以保留结果

SELECT ..., Now(), ... from tableOne

无需将查询嵌入 Java/Scala 程序并仅使用命令行。

Answer 1

使用 Kafka 连接器插入表可以正常工作。首先，我运行使用者并将输出写入文件。然后，我在 Flink SQL 中运行插入，结果可以保存在本地。