Hello,
这个报错,在flink 1.11 最新版本我也遇见了,跟你同样的操作
真正原因是这个ddl 是flink 的sink table,是数据写入端,不能打印数据。
而tableEnv.toRetractStream(table, Row.class).print();
这个打印的数据方法只适合flink 的Source Table,也就是数据输入端,比如kafka table就可以正常使用。
2020年7月9日15:31:56
-- 原始邮件 --
发件人: "出发"<573693...@qq.co
谢谢
-- 原始邮件 --
发件人: Benchao Li
有相应的接口 可以参考hbase的实现
原始邮件
发件人:王志华a15733178...@163.com
收件人:user-zhuser...@flink.apache.org
发送时间:2020年3月13日(周五) 19:17
主题:ddl
目前FLINK中对于DDL这块,它都只能什么类型的技术作为源头表或者SINK 表呢,我也网上也仅仅看到了ddl mysql sink、ddl hbase
sink等。还有其他类型的支持吗?如果不支持的话,是否flink开放了相关的接口,可以提供对其他类型技术的ddl语法支持呢?比如想做一个 ddl kudu
sink之类的 | | 王志华