Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execu

 问题原因:

        在整个代码中没有流算子的存在,因为都是使用table sql的数据类型。

解决办法:

        当没有流的存在时,不要在代码的最后加上env.execute(),其实报错也没问题,照样能运行

猜你喜欢

转载自blog.csdn.net/m0_55868614/article/details/129261507