众所周知,Flink 有两个核心 API(DataStream/DataSet(,但是当我使用 flink Sql 客户端提交作业时,我不需要选择流或批处理模式。那么 Flink SQL 客户端是如何决定使用批处理模式和流模式的。我没有在官方文件中找到答案。 那么,我想知道 Flink SQL 客户端如何区分批处理模式和流模式?
当你启动 Flink 的 SQL 客户端时,你可以通过以下方式指定要使用的环境
sql-client.sh embedded -d <default environment file> -e <session environment file>
环境文件是描述目录和表执行环境的 YAML 文件,包括是使用批处理还是流式处理:
execution:
type: streaming
有关更多详细信息,请参阅文档。