完整報(bào)錯如下:

Exception in thread "main" java.lang.RuntimeException: No new data sinks have been defined since the last execution. The last execution refers to the latest call to 'execute()', 'count()', 'collect()', or 'print()'.
?? ?at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:1085)
?? ?at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:1065)
?? ?at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:962)
?? ?at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:889)
?? ?at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:873)
?? ?at UDF.main(UDF.java:54)
?

?

解決方案：

注釋掉env.execute()

總結(jié)

以上是生活随笔為你收集整理的No new data sinks have been defined since the last execution.的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。