Re: flink sql client 如何同时执行多条 sql 语句

2020-09-09 文章 nicholasjiang
目前Flink SQL Client不支持同时执行多条SQL语句,可以写个程序读SQL文件调用Table API的createStatementSet方式同时执行多条SQL语句。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: pyflink execute_insert问题求解答

2020-09-09 文章 nicholasjiang
1.最终发现只insert了main_table,请问遇见这种情况该怎么处理,就是如何插入多个表? 针对Multiple Sink的话推荐通过Statement Set方式: statement_set = TableEnvironment.create_statement_set() main_table = source.select("...") sub_table = source.select("...") statement_set.add_insert("main_table", main_table)