hi sunfulin, 目前这个做不到。executeSQL 和 table to DataStream 是分别优化和提交作业的。 即使在1.11 之前，table to DataStream 也不会和 sqlUpdate 或者 insertInto 的语句一起优化， 虽然只提交了一个job，但是是两个独立的pipeline，也没有计算复用，和两个job没啥差别。
Best， Godfrey Leonard Xu <[email protected]> 于2020年7月17日周五 上午12:12写道： > Hi， > > 我理解目前好像做不到， cc: godfrey 大佬看看 > > 祝好， > Leonard Xu > > > 在 2020年7月16日，23:08，sunfulin <[email protected]> 写道： > > > > hi， > > 请教下flink 1.11任务提交的问题。如果我的一个作业里既有sql > dml提交（executeSQL执行），又通过DataStream.addSink来写出， > > 通过StreamExecutionEnvironment.execute提交，yarn > per-job貌似会提交两个作业。这种情况下，我该如何处理呢？只想提交一个作业。 > >
