StatementSet inserts = tableEnv.createStatementSet();
inserts.addInsertSql("insert into xxx select * from xxx") // topic1
-》topic2任务
inserts.addInsertSql("insert into xxx select * from xxx") // topic2
-》Postgre 任务
inserts.execute();
--
Sent from: http://apache-flink.147419.n8.nabble.com/
StatementSet 用用
在 2021-03-11 09:37:27，"eriendeng" 写道：
>提交两个SQL，后面的SQL不生效，这是为什么呢？后面的看起来会变成前一个的HA。
>Job1：Kafka Topic1 -> Kafka Topic2
>Job2：Kafka Topic2 -> Postgre
>
>不是很明白这个原因，是不是有哪里没配置好呢？
>
>
>
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/
多个insert的话要用statementset去提交
--
Sent from: http://apache-flink.147419.n8.nabble.com/
提交两个SQL，后面的SQL不生效，这是为什么呢？后面的看起来会变成前一个的HA。
Job1：Kafka Topic1 -> Kafka Topic2
Job2：Kafka Topic2 -> Postgre
不是很明白这个原因，是不是有哪里没配置好呢？
--
Sent from: http://apache-flink.147419.n8.nabble.com/
大家好，我通过Yarn Per
Job模式提交了两个任务，后一个提交的任务会变成前一个一样的任务，而且好像不产生实际作用(?)，看起来像是在给前一个做HA，不知道是不是什么配置没搞好呢？
两个任务分别是 Kafka Topic1 -> Kafka Topic2 和 Kafka Topic2 ->
Postgre，两个任务中的Topic2用的是同一个。
之前也尝试过，Topic1同时写入Topic2和Postgre，好像也同样不会生效，这是为什么呢？
谢谢大家。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
