No new data sinks have been defined since the last execution.
完整报错如下:
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()
No new data sinks have been defined since the last execution.相关推荐
- 【Flink】No new data sinks have been defined since the last execution
在编写Flink(1.9)批处理任务Demo的时候遇到报错,报错详情: Exception in thread "main" java.lang.RuntimeException: ...
- Flink学习笔记（一）：No new data sinks have been defined since the last execution.
问题描述: 初学flink,在IDEA中写离线批处理的wordcount后,运行报了以下异常: Exception in thread "main" java.lang.Runti ...
- No new data sinks have been defined since the last execution
报错: Exception in thread "main" java.lang.RuntimeException: No new data sinks have been def ...
- flink报错：No new data sinks have been defined since the last execution
初学flink,在IDEA上编写WordCount代码运行报错如下: Exception in thread "main" java.lang.RuntimeException: ...
- Flink error：No data sinks have been created yet. A program needs at least one sink that consumes dat
一.问题描述 Flink程序,批处理程序,执行报错: Exception in thread "main" java.lang.RuntimeException: No data ...
- Flink开发环境搭建（maven）
1.下载scala sdk http://www.scala-lang.org/download/ 直接到这里下载sdk,(https://downloads.lightbend.com/scala/ ...
- Flume中sources、channels、sinks的常用配置（多个案例）
Flume中sources.channels.sinks的常用配置(多个案例) 文章目录 Flume中sources.channels.sinks的常用配置(多个案例) Flume基础及架构 案例1: ...
- 1.10.Flink DataStreamAPI(API的抽象级别、Data Sources、connectors、Source容错性保证、Sink容错性保证、自定义sink、partition等)
1.10.Flink DataStreamAPI 1.10.1.Flink API的抽象级别 1.10.2.DatSource部分详解 1.10.2.1.DataStream API之Data Sou ...
- springmvc sends and receives data by ajax request using json format
[0]README 1) springmvc sends or receives data by ajax request using json format; [1] ajax function & ...
最新文章
- 关于Nikon Ai AF 28mm F1.4D遮光罩的问题
- MCMC(二)马尔科夫链
- 最小最大定理 java_Java基础50道经典练习题（35）——最大最小交换
- TFS 解除独占锁定
- ArcGIS Engine 10.2开发环境搭建
- HTML边框百分比,CSS：以百分比和边框表示的宽度
- java -jar 内存溢出_JAVA系统启动栈内存溢出-StackOverflowError
- [Web Chart系列之一]Web端图形绘制SVG,VML, HTML5 Canvas 技术比较
- python超链接格式_用Python在本地文件夹中插入超链接
- 笔记本用PCIE转并口卡连接H-JTAG烧写PXA270 NOR Flash
- [原创] 婚纱照PS处理技术精粹（视频教程1.2G免费下载，11个核心技术点）
- Silvaco TCAD仿真10——MOSFET结构仿真
- 电脑浏览android,直接在电脑上浏览操作安卓手机
- vim快捷键（一）查找与替换
- 信息系统集成-模拟二错题
- 第五季完美童模 代言人陈梓桐 现场走秀回顾
- 读取存储《哈姆雷特》英文剧本的文件，分析统计其中单词出现的频率,实现以下结果:给出前10个人物出现的次数使用turtle模块绘制词频统计结果；使用wordcloud库会出词云图；
- android 系统下载管理器
- 基于Opencv实现连续检测yuv转bmp后的每一帧的sobel算法实现
- Citrix HDX 3D 优化建议