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. ...
最新文章
- MATLAB 随机过程基本理论
- 不可小视的贝叶斯（一）
- scala解析csv文件写入mysql_scala实战之spark源码修改（能够将DataFrame按字段增量写入mysql数据表）...
- 某大型银行深化系统技术方案之六：系统架构之运作流程
- java 中的radix_线程“main”中的异常java.lang.NumberFormatException：Radix超出范围
- vue.js 父子组件间 props 数据同步处理
- 【大数据部落】R语言如何使用rjags R2jags来建立贝叶斯模型
- Caffe学习1-图像识别与数据可视化
- ubuntu 设置静态路由_Linux route 配置静态路由(转载)
- 2022-07-17 mysql使用的flex/yacc语法练习
- 计算机组成原理期末考试题库(超级多的那种)
- 弱电工程施工组织设计
- 微信小程序弹框的使用
- RPM包安装相关命令
- 使用svn向指定文件夹下载数据
- 防火门建筑材料英国UKCA认证—EN 16034
- Sicily1059-Exocenter of a Trian
- idea中Entity实体中报错：cannot resolve column/table/...解决办法。
- 小红帽蜘蛛池租用百万蜘蛛秒收录
- IT大佬告诉你大数据有哪些特点，新人学习必知