flink程序报ClassCastException

java.lang.ClassCastException: cannot assign instance of com.starrocks.connector.flink.table.StarRocksSinkOptions to field com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.sinkOptions of type com.starrocks.connector.flink.table.sink.StarRocksSinkOptions in instance of com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor

同事安装其他软件给环境弄挂了一次,然后flink任务就起不来了

从报错看是通信问题,10.247.200.159这台机器是fe还是be?看下各个机器之前的通信是否存在问题

是fe 目前切换了

我看网上也说是FE和BE通信的问题,但不知道怎么排查和解决

你这台是master吗?看看master fe节点是否还存活?

这个原先是master 挂了之后就master就切换到别的服务器了

fe master是alive的?

我记得之前是159 挂了之后发生了切换了

看这个’/frontends’是活着的

image

master是活着的

telnet一下看看两台fe是不是通的,另外如果机器有混部的话也show backends看看各个be的alive状态

看了be的状态是没问题,teInt 9020两个fe也是通的

最主要就是这个flink启动报错

用的是 flink-connector-starrocks?发下sink端代码?

之前还好好的 就挂了之后就不行了 也不知道咋回事 一启动就报上面的问题

OK 了解,

请问这个部分怎么写的呢?