flink getExecutionPlan 執行計劃可視化

Flink 內置了一個執行計劃的可是化工具。http://flink.apache.org/visualizer/index.html 代碼示例 object MyApp extends App { private val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1)

>>阅读原文<<