为了更快的定位您的问题,请提供以下信息,谢谢
【详述】flink读取sr表,表中含有json字段
【背景】flink读取sr表
【业务影响】高
【是否存算分离】否
【StarRocks版本】例如:3.2.4
【集群规模】例如:3fe(3 follower)+3be(fe与be分离部署)
【机器信息】8c32g万兆
【联系方式】1583425949@qq.com
Caused by: java.lang.RuntimeException: Failed to open scanner.INVALID_ARGUMENT[Unknown primitive type(27)]
at com.starrocks.connector.flink.table.source.StarRocksSourceBeReader.openScanner(StarRocksSourceBeReader.java:128)
at com.starrocks.connector.flink.table.source.StarRocksDynamicSourceFunction.lambda$open$0(StarRocksDynamicSourceFunction.java:150)
at java.util.ArrayList.forEach(ArrayList.java:1257)
at com.starrocks.connector.flink.table.source.StarRocksDynamicSourceFunction.open(StarRocksDynamicSourceFunction.java:148)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:110)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:708)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:684)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:651)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
at java.lang.Thread.run(Thread.java:748)