Блог

Поскольку я знаю, что Flink поддерживает локальный режим выполнения (см. https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/dataset/local_execution /).

Но я хочу выполнить пакетный sql в flink, используя локальную среду выполнения CollectionEnvironment, чтобы поддерживать соответствие с онлайн-обслуживанием и автономным обучением -разработка функций набора данных.

Кто-нибудь может сказать мне, как использовать локальный режим для выполнения пакетного sql?

API DataSet устарел в 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';