谢谢!!!

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

回复