【详述】问题详细描述
【背景】做过哪些操作？几个百万级mysql表通过flinkcdc 做join后 sink到Starrocks，flink状态后端为RocksDB
【StarRocks版本】1.19.3
【集群规模】1fe+1be(单机测试)
直接操作SR能正常建表、查询和删除。请问是哪方面的问题？
【报错日志】
java.lang.RuntimeException: Writing records to StarRocks failed.
at com.starrocks.connector.flink.manager.StarRocksSinkManager.checkFlushException(StarRocksSinkManager.java:290)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.writeRecord(StarRocksSinkManager.java:163)
at com.starrocks.connector.flink.table.StarRocksDynamicSinkFunction.invoke(StarRocksDynamicSinkFunction.java:136)
at org.apache.flink.table.runtime.operators.sink.SinkOperator.processElement(SinkOperator.java:65)
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:205)
at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:66)
at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:423)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:204)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
at org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
Suppressed: java.lang.RuntimeException: Writing records to StarRocks failed.
at com.starrocks.connector.flink.manager.StarRocksSinkManager.close(StarRocksSinkManager.java:213)
at com.starrocks.connector.flink.table.StarRocksDynamicSinkFunction.close(StarRocksDynamicSinkFunction.java:172)
at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:117)
at org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:864)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runAndSuppressThrowable(StreamTask.java:843)
at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:756)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:662)
… 4 more
Caused by: java.lang.RuntimeException: Writing records to StarRocks failed.
at com.starrocks.connector.flink.manager.StarRocksSinkManager.checkFlushException(StarRocksSinkManager.java:290)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.flush(StarRocksSinkManager.java:183)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.close(StarRocksSinkManager.java:211)
… 11 more
Caused by: java.io.IOException: java.io.IOException: None of the hosts in load_url could be connected.
at com.starrocks.connector.flink.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:272)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.access$000(StarRocksSinkManager.java:52)
at com.starrocks.connector.flink.manager.StarRocksSinkManager$1.run(StarRocksSinkManager.java:120)
… 1 more
Caused by: java.io.IOException: None of the hosts in load_url could be connected.
at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doStreamLoad(StarRocksStreamLoadVisitor.java:69)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:258)
… 3 more
Caused by: [CIRCULAR REFERENCE: java.io.IOException: java.io.IOException: None of the hosts in load_url could be connected.]
检查一下smt配置config_prod.conf中的loadurl是否书写正确，网络打通，端口配置正确。如果需要修改smt配置，修改后需要重新生成sql脚本
提交的Flink job能够运行一段时间，也成功写入了几万条数据，说明loadurl应该是没问题的，网络用的是内部局域网。flink job上游出现了严重的背压(应该是多表join造成的)。
又复现了下，观察到 上游join较慢出现背压，下游有一段时间没有数据到SR，3分钟左右后上游数据又推送一批到SR，此时报了这个错误。像连接过期一样
哦对了刚看懂，没用过smt，只用了Flink-cdc-connector，整个流程是这样的 flinkcdc——》join+group by ——》upsertkafka——》SR，因为要做join和聚合，SR作初步的DWS表
解决了吗，也遇到了同样的问题，Caused by: java.lang.IllegalArgumentException: None of the hosts in load_url could be connected.
任务挂掉重启之后就好，但是时不时的可能就遇到这个错了然后重启又正常
你解决了吗 我也遇到了没解决，这个问题这么久社区都没大佬跟进啊
1.2.4_flink-1.14_2.12
用这个版本就正常了 ，新版的connector有问题
新版的connector有问题指的是 1.2.8，请问下具体是什么问题呢