Flink: No operators defined in streaming topology. Cannot execute
需要增加print(), 类似spark 中需要触发算子一样
env.print()
env.execute("Test Job")

Flink: No operators defined in streaming topology. Cannot execute
需要增加print(), 类似spark 中需要触发算子一样
env.print()
env.execute("Test Job")