回复: Re:flink1.18 on yarn提交任务生成多个application

Mon, 01 Jul 2024 20:42:43 -0700 

你好，感谢回复，请问有官网文档么，我想详细了解下，谢谢！
________________________________
发件人: 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
>
>
>请问这是什么原因

回复