Flink：一个程序中的数据集和数据流API。有可能吗？

Question

我想首先使用dataset API操作静态数据，然后使用DataStream API运行流作业。如果我在IDE上编写代码，它工作得很好。但是当我尝试在本地flink jobmanager上运行时（全部并行性1)，流式代码从未执行过！

例如，以下代码不起作用：

val parallelism = 1

val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism(parallelism)

val envStatic = ExecutionEnvironment.getExecutionEnvironment
envStatic.setParallelism(parallelism)

val myStaticData = envStatic.fromCollection(1 to 10)
val myVal: Int = myStaticData.reduce(_ + _).collect().head

val theStream = env.fromElements(1).iterate( iteretion => {
  val result = iteretion.map(x => x + myVal)
  (result, result)
})
theStream.print()
env.execute("static and streaming together")

执行计划：计划似乎是一个循环。

Answer 1

如果Flink作业由多个子作业组成，例如由计数、收集或打印触发，则无法通过web界面提交作业。web界面只支持单个Flink作业。