暂无个人介绍
2022年01月
Hive 不支持 Flink CDC 的语义,不能像 TiDB、Doris 那样直接落盘,但是 Hive 上存储有大量离线历史数据,如何更方便的打通这些实时热数据与离线冷数据的交互。
我也遇到了楼主同样的报错,我这边是因为flink 配置文件 flink-conf.yaml 中 配置了 high-availability.cluster-id: /cluster_one,这时如果使用同一个配置文件启动多个flink yarn session,会导致 high-availability.cluster-id 冲突,
解决方法是:
1.去掉该配置项 high-availability.cluster-id: /cluster_one。
2.每启动一个flink yarn session之前,修改 high-availability.cluster-id的值为不同的值,然后同步配置文件到整个集群中