Flink-Dataset-Flink 能否尊重多个流/输入的处理顺序？

Question

在我的 Flink 批处理程序 (DataSet / Table ) 中，我正在读取多个文件，这会产生不同的流，进行一些处理，并以输出格式保存它
由于flink使用的是dataflow模型，和我的flows没有太大关系，所以是并行处理

但我希望 Flink 至少尊重我输出操作的顺序，因为我希望 flow1 在 flow2 之前保存

例如我有这样的东西：

Table table1 = tableEnv.fromTableSource(new MyTableSource1());
DataSet<Obj1> dataSet1 = talbeEnv.toDataSet(table1.select("toto",..),Obj1.class)
dataSet1.output(new WateverdatasinkSQL())

Table table2 = tableEnv.fromTableSource(new MyTableSource2());
DataSet<Obj2 dataSet2 = tableEnv.toDataSet(table2.select("foo","bar",..),Obj2.class)
dataSet2.output(new WateverdatasinkSQL())

我想让flink等待dataSet1保存后继续...
我怎样才能将它作为连续操作来完成？
我已经查看了执行模式，但这不是这样做的

此致， 巴斯蒂安

Answer 1

最简单的解决方案是将两个流程分成单独的作业并一个接一个地执行。

Table table1 = tableEnv.fromTableSource(new MyTableSource1());
DataSet<Obj1> dataSet1 = talbeEnv.toDataSet(table1.select("toto",..), Obj1.class);
dataSet1.output(new WateverdatasinkSQL());
env.execute();

Table table2 = tableEnv.fromTableSource(new MyTableSource2());
DataSet<Obj2> dataSet2 = tableEnv.toDataSet(table2.select("foo","bar",..), Obj2.class);
dataSet2.output(new WateverdatasinkSQL());
env.execute();