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:
toAppendStream doesn't support consuming update and delete changes which is produced by
node Join(joinType=[LeftOuterJoin], where=[(leftxxx = rightxxx)], select=[xxx, xxx, xxx, xxx, xxx, xxx, xxx], leftInputSpec=[NoUniqueKey], rightInputSpec=[NoUniqueKey])

代码是执行一个table join语句：

Table table = table2.leftOuterJoin(table3, "leftxxx = rightxxx").select("xxx,xxx,xxx,xxx,xxx,xxx");

最后输出结果到控制台：

tEnv.toAppendStream(table, Row.class).print("res");

这个结果table是由节点联接产生的，toAppendStream不支持消费更新和删除更改
故改成：

tEnv.toRetractStream(tableCTNR, Row.class).print("res");

他的结果是带有一个Boolean标志的的数组，true表示添加数据，false表示撤回

toAppendStream doesn‘t support consuming update and delete changes which is produced by node XXX相关推荐

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. ...
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 doesn't support consuming update and delete changes 错误谈起
前言相信我们在初学Flink SQL时,多少遇到过像这样的错误信息: org.apache.flink.table.api.TableException: X[算子名] doesn't suppor ...
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 ...
【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 ...
【SQL】Attempt to do update or delete using transaction manager that does not support these operations
在Hive SQL中执行update或者delete语句,报错: FAILED: SemanticException [Error 10294]: Attempt to do update or de ...
让Hive支持行级insert、update、delete
首先:欢迎各位学习java和大数据的程序员朋友们加入Java交流学习群: 721506929群里提供免费的架构学习资料,直播讲解,讲师都是有着十几年阿里java开发经验的大牛,欢迎各位前来围观学习. ...
Attempt to do update or delete on table educator.t_item_info that does not use an AcidOutputFormat o
Attempt to do update or delete on table educator.t_item_info that does not use an AcidOutputFormat o ...
Hive支持Update和Delete语句
https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DML#LanguageManualDML-Update 文档说了hiv ...

toAppendStream doesn‘t support consuming update and delete changes which is produced by node XXX

toAppendStream doesn‘t support consuming update and delete changes which is produced by node XXX相关推荐

最新文章

热门文章