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)
statement_set.add_insert("sub_table", sub_table)
2.for i in range(1,20):
sub_table = source.select("...%s...%d...."
%(str(i),i))#我的select语句是一个动态拼接的sql，在一个for循环中，获取多个sub_table
sub_table.execute_insert('sink').get_job_client().get_job_execution_result().result()
#这种方式是否合理，因为也是测试无法插入多个表，有没有什么解决方案
按照上述方式进行Multiple Sink是可以插入多个表。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
