Flink1.12 如何使用代码提交Batch的Sql

Thu, 04 Mar 2021 17:59:16 -0800 

我们知道如果在1.12里使用Table API来提交Batch的作业，比如：
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setRuntimeMode(RuntimeExecutionMode.BATCH);

但是，如果提交Sql作业的话：
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
Table result = tableEnv.sqlQuery(...);
文档里也找不到如何使用StreamTableEnvironment 来跑Batch的SQL，又或者使用BatchTableEnvironment？

感谢各位提供思路！





--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复