StatementSet 里添加多个insertsql执行

[op]

大家好，我发现StatementSet 里添加2个insertsql执行的时候会启动两个application，
这两个任务除了sink都是一样的吗？这样是不是会重复计算和浪费资源，而且两边的数据可能不同步，
有什么办法能解决？
谢谢

[godfrey he]

StatementSet 中的多个insert会被编译成一个job提交。
你能提供一下对应的代码样例吗？

op <[hidden email]> 于2020年7月30日周四 下午3:57写道：

> 大家好，我发现StatementSet 里添加2个insertsql执行的时候会启动两个application，
> 这两个任务除了sink都是一样的吗？这样是不是会重复计算和浪费资源，而且两边的数据可能不同步，
> 有什么办法能解决？
> 谢谢

[op]

不好意思，我找到问题了，因为我再程序里面除了调用statement.execute外还调用了streamEnv.execute
所以起了两个app，
谢谢


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年7月30日(星期四) 下午4:01
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: StatementSet 里添加多个insertsql执行



StatementSet 中的多个insert会被编译成一个job提交。
你能提供一下对应的代码样例吗？

op <[hidden email]&gt; 于2020年7月30日周四 下午3:57写道：

&gt; 大家好，我发现StatementSet 里添加2个insertsql执行的时候会启动两个application，
&gt; 这两个任务除了sink都是一样的吗？这样是不是会重复计算和浪费资源，而且两边的数据可能不同步，
&gt; 有什么办法能解决？
&gt; 谢谢