如题,详细报错就是:
Caused by: org.apache.doris.flink.exception.DorisBatchLoadException: stream load error: stream load error, response is {"status":"FAILED","msg":"errCode = 2, detailMessage = No cloud cluster name selected."}。
flink cdc代码如下:
sink:
type: doris
fenodes: xx.xxx.xx.xx:8030
username: xx
password: "xxxxxxx"
table.create.properties.light_schema_change: true
table.create.properties.replication_num: 1
这段代码之前向doris 2.x 存算一体集群写入是没有问题的,什么原因呢,要制定什么云集群名称,看Stream Load配置里面也没有相似的东西