Flink Sql -- toAppendStream doesn‘t support consuming update and delete changes which

在Flink sql进行测试输出， 想把 sql查询的结果Table 转为DataStream 然后进行打印

当我们table.toAppendStream[Row]的时候 发现报错

其实这个因为我们sql 查的那个动态表 是Mysql 这类源， 他们是可以进行update,delete,insert操作的。

对于toAppendStream呢 是仅可以将追加流进行转换输出 比如kafka

所以我们使用

table.toRetractStream[Row].print() 即可
这操作呢打印结果是一个有两部分， 前面部分为boolean类型， 后面是你的select 其中 true表示insert ，false表示 update/delete

 table.toRetractStream[Row].print()  即可 
 tableEnv.toRetractStream(table,EventLog.class).print();

对于Table / sql 转 Stream 可以看官网也有详细的讲解
官网