我正在做一个Flink流作业,我需要在Hudi表中插入数据。我使用合并进入查询来在Hudi表中插入数据。Table table = tableEnv.fromDataStream(KafkaStreamTableDataStreamStream);
tableEnv.createTemporaryViewBut it is giving me Exception in thread "main" org.apache.flink.table.api.TableException: Unsupportedquery
在org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:625) at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(OperatorChain.java:533),org.apache.flink。:657) at org.apache.flink.streaming.api.operators.Strea
我使用的是Flink 1.12,我有以下简单的代码来演示数组类型column的用法。我想要获取收藏夹数组列中的第二个元素,但是当我运行应用程序时,以下异常抛出: Type is not supported: ANY at org.apache.flink.table.planner.calcite.FlinkTypeFactory$.toLogicalType(FlinkTypeFactory.
'orderRecAmount, 'orderRecDate) // occur error hereException in thread "main" org.apache.flink.table.api.TableException: Table of atomic type can only have a single field.
at org.apache.flink.table.api.TableEnvironment$$anonfun$1.apply(TableE