Flink No operators defined in streaming topology. Cannot execute.
Exception in thread “main” java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.
Exception in thread “main” java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraphGenerator(StreamExecutionEnvironment.java:2000)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1991)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1976)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1822)
at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:746)
at com.ultrapower.realtime.test.MyTestScala$.main(MyTestScala.scala:18)
at com.ultrapower.realtime.test.MyTestScala.main(MyTestScala.scala)
因为程序中没有定义操作，将source.print()注释掉就报错了，不注释就不会报错
Flink No operators defined in streaming topology. Cannot execute.相关推荐
- flink Sql 1.11 executeSql报No operators defined in streaming topology. Cannot generate StreamGraph.
报错信息如下: Exception in thread "main" java.lang.IllegalStateException: No operators defined i ...
- Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execu
问题原因: 在整个代码中没有流算子的存在,因为都是使用table sql的数据类型. 解决办法: 当没有流的存在时,不要在代码的最后加上env.execute(),其实报错也没问题,照样能运行
- Flink X Hologres构建企业级Streaming Warehouse
摘要:本文整理自阿里云资深技术专家,阿里云Hologres负责人姜伟华,在FFA实时湖仓专场的分享.点击查看>>本篇内容主要分为四个部分: 一.实时数仓分层的技术需求 二.阿里云一站式实时 ...
- Flink x Zeppelin ，Hive Streaming 实战解析
行业解决方案.产品招募中!想赚钱就来传!>>> Flink 1.11 正式发布已经三周了,其中最吸引我的特性就是 Hive Streaming.正巧 Zeppelin-0.9-pre ...
- 大数据框架 Flink、Blink、Spark Streaming、Structured Streaming 和 Storm 之间的区别
在 1.2 节中已经跟大家详细介绍了 Flink,那么在本节就主要 Blink.Spark Streaming.Structured Streaming 和 Storm 的区别. Flink Flin ...
- Flink 算子Operators总结
Operator 作用 流的转换 map 将一个元素转换成另外一个元素 DataStream → DataStream本 flapmap 将几个的一个元素转换为零个,一个或者多个 DataStream ...
- E1: 在idea中执行flink程序时报错 No ExecutorFactory found to execute the application.
在idea中运行flink程序报错,详细报错信息如下: Exception in thread "main" org.apache.flink.table.api.TableExc ...
- 聊聊flink的Execution Plan Visualization
为什么80%的码农都做不了架构师?>>> 序 本文主要研究一下flink的Execution Plan Visualization 实例 代码 @Testpublic void ...
- flink streamGraph生成
当完成DataStream的配置后,调用其中环境上下文StreamExecutionEnvironment的getStreamGrahph()方法即可生成关于该DataStream的streamGra ...
- Flink数据流DataStream
准备 final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env. ...
最新文章
- 计算机基础知识精品课程,计算机应用基础精品课
- 前端小白也能快速学会的博客园博客美化全攻略
- 2017.9.30 物流运输 思考记录
- 接口测试如何在post请求中传递文件
- 推荐几个超实用公众号，与众不同
- WPF UI框架界面开发教程（一）
- AI创作现状与未来发展浅析
- 3.微信小程序--快速开发UI界面
- 强力回击 跨境侵权（TRO）卖家通过诉讼大获全胜，还净赚数万？
- 形式语言与自动机 第4章 正规文法和正规集的性质
- 为什么那么都程序员不敢学Python？
- pprint和print区别
- Single image dehazing (Fattal)
- Java并发Future
- pycharm PEP8规范(python)
- bzoj3875 [Ahoi2014Jsoi2014]骑士游戏
- 简单介绍psutil库（virtual_memory()、cpu_percent()
- 【打开硬盘文件夹报回收站损坏是否清空】
- 我读 《异类》 - 马尔科姆 · 格兰德威尔 / 马太效应
- Git：解决Your branch is ahead of ‘origin/master‘ by N commits问题