问答 2018-11-15 来自:开发者社区

【Flink】报错 'Rds' is not supported as a source table.

错误描述【语法检查】报错提示:ERR_ID: CON-00012CAUSE: 'Rds' is not supported as a source table.ACTION: Check the doc for more information报错原因作业中声明了RDS的表,但是没有INSERT该表。RDS作为维表,但是没有声明维表PERIOD FOR SYSTEM_TIME。

问答 2018-10-18 来自:开发者社区

请教下,Flink里面把流注册为表: tableEnv.registerDataStream("mytable", mystream ....) 这里的流 mystream 貌似必须是append only流,不能是retraction流。这是为什么?如果是retraction流,报错Table is not an append-only table. Use the toRetractStream() in order to handle add and retract messages.

转自钉钉群21789141:请教下,Flink里面把流注册为表: tableEnv.registerDataStream("mytable", mystream ....)这里的流 mystream 貌似必须是append only流,不能是retraction流。这是为什么?如果是retraction流,报错Table is not an append-only table. Use the ....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注