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 > > >请问这是什么原因