谢谢!!!
祝好运, Liu ________________________________ 发件人: Xuyang <xyzhong...@163.com> 发送时间: 2024年7月2日 14:00 收件人: user-zh@flink.apache.org <user-zh@flink.apache.org> 主题: Re:回复: Re:flink1.18 on yarn提交任务生成多个application 可以参考下这[1] Tips: 社区新语法EXECUTESTATEMENTSET BEGIN ... END; ,也可以用 begin statement set; ... end; [1]https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/sql/insert/#insert-into-multiple-tables -- Best! Xuyang 在 2024-07-02 11:42:32,"Liu Join" <lzy139...@outlook.com> 写道: >你好,感谢回复,请问有官网文档么,我想详细了解下,谢谢! >________________________________ >发件人: Xuyang <xyzhong...@163.com> >发送时间: 2024年7月2日 11:25 >收件人: user-zh@flink.apache.org <user-zh@flink.apache.org> >主题: Re:flink1.18 on yarn提交任务生成多个application > >Hi, 如果是不想出现两个application的情况,可以试一下使用statement >set将两个dml放在一起。否则的话,会被视为两个单独的操作,分成两个application。 > > > > >sql: begin statement set; ... end; > >java & scala table api: tableEnv#createStatementSet > > > > >-- > > Best! > Xuyang > > > > > >在 2024-07-02 10:04:34,"Liu Join" <lzy139...@outlook.com> 写道: >>版本:flink1.18、hadoop3.0.0 >>提交方式:per-job >> >>问题: >>1. 使用flink sql编写的程序,数据源相同,输出定义了一个doris >>sink,以及一个表转流的print,将jar包提交到yarn会生成两个application,一个输出为doris >>sink,另一个输出为流转表的print >> >>2. 使用flink sql编写的程序,数据源相同,输出定义了两个doris >>sink,表a和表b,将jar包提交到yarn会生成两个application,一个输出为doris sink表a,另一个输出为doris sink表b >> >> >>请问这是什么原因