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

Question

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

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

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

标签： bigdataapache-flink

Answer 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';