toAppendStream doesn‘t support consuming update changes which is produced by node GroupAggregate
Exception in thread "main" org.apache.flink.table.api.TableException: toAppendStream doesn't support consuming update changes which is produced by node GroupAggregate(groupBy=[amount, product, user], select=[amount, product, user])
解决方案:
tEnv.toAppendStream(result, Row.class).print();
env.execute();
改成:
tEnv.toRetractStream(result, Row.class).print();
env.execute();
toAppendStream doesn‘t support consuming update changes which is produced by node GroupAggregate相关推荐
- toAppendStream doesn‘t support consuming update and delete changes which is produced by node XXX
bug如下: Exception in thread "main" org.apache.flink.table.api.TableException: toAppendStrea ...
- Table sink ‘default_catalog.default_database.t3‘ doesn‘t support consuming update and delete changes
报错:Table sink 'default_catalog.default_database.t3' doesn't support consuming update and delete chan ...
- Flink sql:Table sink doesn‘t support consuming update and delete changes which is produced by node
一.问题描述 Flink sql将kafka作为join的输出,报错: Exception in thread "main" org.apache.flink.table.api. ...
- 从Flink SQL doesn't support consuming update and delete changes 错误谈起
前言 相信我们在初学Flink SQL时,多少遇到过像这样的错误信息: org.apache.flink.table.api.TableException: X[算子名] doesn't suppor ...
- 【Flink】FLink SQL TableException: Table sink doesn‘t support consuming update changes which is
文章目录 1.概述 2.原因 3.解决方案 1.概述 在做实验:[Flink]Flink SQL 读取 CSV 文件 最后尝试将数据写入到csv文件的时候报错. Flink SQL> INSER ...
- 项目执行maven update时，报：Preference node org.eclipse.wst.validation
参考:http://blog.csdn.net/u013474104/article/details/43866747 详细情况如下: An internal error occurred durin ...
- Maven学习总结（26）——maven update时，报：Preference node org.eclipse.wst.validation...
详细情况如下: An internal error occurred during: "Updating Maven Project". Preference node " ...
- 项目执行maven update时，报：Preference node org.eclipse.wst.validation...
详细情况如下: An internal error occurred during: "Updating Maven Project". Preference node " ...
- 2021年大数据Flink（三十五）：Table与SQL 案例二
目录 案例二 需求 代码实现-SQL 代码实现-Table 案例二 需求 使用SQL和Table两种方式对DataStream中的单词进行统计 代码实现-SQL package cn.it.sql;i ...
最新文章
- mysql plugin filed_MySQL启动时报Plugin 'InnoDB' registration as a STORAGE ENGINE failed.错误
- 【Python】全网最新最全Pyecharts可视化教程(三)：制作多个子图
- LiveVideoStackCon上海2019音视频技术大会 7折早鸟票最后3天
- 洛谷 P1757 通天之分组背包
- win10 桌面的的文件都不见了 提示不注销保存都文件都为临时_Windows10隐藏的8个小技巧，每一个都非常实用又高效...
- 新手程序员必学的代码编程技巧
- zk框架实现zul的js代码调用服务器java命令
- U盘插入电脑说要格式化，但电脑又说“磁盘被写保护，无法格式化”，如何解决
- Eclipse版本代号
- 5G知识之5G技术指标、应用场景及相关技术（零星版）
- 2014年大数据解决方案提供商面临三大挑战
- InfluxDB常用函数
- 时区、时间戳、日期、夏令时、冬令时
- 【二叉树】重建二叉树
- 系统响应及系统稳定性
- 蔡琳高梓淇跨国姐弟恋微博曝光 经典剧照盘点
- 高级可视化神器Plotly快速入门
- 性能指标：QTS， 并发数， TPS
- 挖掘大数据的商业价值
- 虚拟容器LXD命令详解