java - 一个 Flink 作业中有两个数据流

Question

我在一个 flink 作业中有两个无限的 kafka 数据流，如下所示:

StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
DataStream kafka1 = ...
DataStream kafka2 = ...

kafka1.process();
kafka2.process();

environment.execute();

两个流的处理是并行的还是顺序的？

Answer 1

如果只使用一个环境，任务将并行运行。