flink getExecutionPlan 执行计划可视化

Flink 内置了一个执行计划的可是化工具。http://flink.apache.org/visualizer/index.html 代码示例 object MyApp extends App { private val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1)

>>阅读原文<<