执行了一个 insert，执行了一个自定义的sink 提交到yarn会生成俩job 有办法合成一

楼主你好，可以尝试使用 Apache Flink 的 StreamExecutionEnvironment 来实现数据流的合并，具体步骤如下：

1. 创建一个 StreamExecutionEnvironment 对象，并指定运行环境为 Yarn。
2. 使用 addSource 方法读取阿里云的数据源，将数据流转换为 DataStream 对象。
3. 使用 addSink 方法将数据流写入自定义的 Sink。
4. 调用 execute 方法启动任务。

示例代码：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setRuntimeMode(RuntimeExecutionMode.YARN); // 设置运行环境为 Yarn

DataStream<Row> sourceStream = env.addSource(...); // 读取阿里云数据源

sourceStream.addSink(...); // 写入自定义 Sink

env.execute("Job Name"); // 启动任务

这样做的好处是可以将两次提交合并成一个任务，提高执行效率。