如何在 Flink 中使用本地执行模式执行批处理 sql？

Posted 2023-04-18

【中文标题】如何在 Flink 中使用本地执行模式执行批处理 sql？

【英文标题】：How to execute batch sql using local execution mode in Flink?

【发布时间】：2021-11-16 09:04:58

【问题描述】：

据我所知，Flink 支持本地执行模式（参考https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/dataset/local_execution/）。

但我想在 flink 中使用本地执行 CollectionEnvironment 执行批处理 sql，以与在线服务和离线训练数据集特征工程保持一致。

谁能告诉我如何使用本地模式执行批处理sql？

【参考方案1】：

DataSet API 在 Flink 中已被弃用，所以我建议你改用 Table API/SQL。

使用 Flink SQL 客户端，可以设置执行模式。见https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/sqlclient

您要查找的设置是： SET 'execution.runtime-mode' = 'batch';

【讨论】：

谢谢。 TableApi/SQL 没问题。以及如何在批处理sql中指定collectionExecutor(CollectionEnvironment)？