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

Thu, 04 Mar 2021 20:48:51 -0800 

感谢Qishang同学的回复！

我主要的目标是往一个运行的Flink集群上提交SQL，因为需要开窗写hive表，只能提交Batch的SQL。

如果是stream的，我是这么提交Sql，可以提交到Flink集群上：
final StreamExecutionEnvironment env = 
                
StreamExecutionEnvironment.createRemoteEnvironment("tkbd01", 8081);
        //StreamExecutionEnvironment bsEnv =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings bsSettings = 
                       
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(env,
bsSettings);
//TableEnvironment bsTableEnv = TableEnvironment.create(bsSettings);

但是这个是*StreamExecutionEnvironment 没有办法执行BatchMode*
矛盾的地方在于 如果使用  TableEnvironment bsTableEnv =
TableEnvironment.create(bsSettings);  来执行Batch sql，又没有办法*通过final
StreamExecutionEnvironment env   来创建TableEnvironment*。





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

回复