使用flink sql 查询数据报错如下

【详述】打算批处理starrocks里面数据
【StarRocks版本】2.32
【集群规模】例如:3fe(1 follower+2observer)+5be(fe与be混部)
【表模型】主键模型
表结构: CREATE TABLE ads_vehicle_test (
id varchar(100) NOT NULL COMMENT “分区年月”,
name varchar(100) NOT NULL COMMENT “统计维度”
) ENGINE=OLAP
PRIMARY KEY(id)
COMMENT “OLAP”
DISTRIBUTED BY HASH(id) BUCKETS 2
PROPERTIES (
“replication_num” = “2”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “false”
);
代码:


图片报错信息:

是不是connector选错了,通过flink将starrocks数据导出可以参考这个 https://docs.starrocks.io/zh-cn/2.5/unloading/Flink_connector

老师 按照你的文档把maven 中 flink-connector-starrocks 版本升级了 ,数据就好使了 读取出来了 ,但是报错2023-05-17 16:12:00 WARN [org.apache.flink.streaming.api.operators.collect.CollectResultFetcher] Failed to get job status so we assume that the job has terminated. Some data might be lost.
java.lang.IllegalStateException: MiniCluster is not yet running or has already been shut down.