I have feagured this out.
It was because I put a flink-connector-tidb-cdc.jar in my Flink's lib folder
earlier, and it is shipped with scala 2.11, while my flink is shipped with
scala2.12.
Some how when I submit a job with GroupAggregate operator, it needs to load
keyed rocksdb states, and he
You're probably mixing Flink versions.
From the stack trace we can see that Flink classes are being loaded
from 2 different jars
(rocketmq-flink-1.0.0-SNAPSHOT.jar/flink-dist_2.12-1.13.5.jar); I'd
suggest to resolve that first and see if the error persists.
On 23/05/2022 14:32, 李诗君 wrote:
f
flink version: 1.13.5
java code:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings settings = EnvironmentSettings.newInstance()
.useBlinkPlanner()
.inStreamingMode()
.build();
StreamTable
