【详述】问题详细描述
【背景】做过哪些操作？
【业务影响】
【StarRocks版本】2.4.2
【集群规模】3fe（1 follower+2observer）+20be
【机器信息】CPU虚拟核/内存/网卡，例如：40C/512G/万兆
【表模型】明细模型
【导入方式】Flink
【联系方式】社区群4-王磊
【附件】
- fe.log/be.INFO/相应截图
fe.zip (29.2 MB)
taskmanager_container_e04_1671099865510_383307_01_000002_log.txt (730.4 KB)
2023-01-05 14:12:59,006 WARN com.netease.sloth.flink.connector.starrocks.manager.StarRocksStreamLoadVisitor [] - Failed to connect to address:http://192.168.8.186:8030
java.net.SocketTimeoutException: connect timed out
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[?:1.8.0_152]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[?:1.8.0_152]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[?:1.8.0_152]
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[?:1.8.0_152]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_152]
at java.net.Socket.connect(Socket.java:589) ~[?:1.8.0_152]
at sun.net.NetworkClient.doConnect(NetworkClient.java:175) ~[?:1.8.0_152]
at sun.net.www.http.HttpClient.openServer(HttpClient.java:463) ~[?:1.8.0_152]
at sun.net.www.http.HttpClient.openServer(HttpClient.java:558) ~[?:1.8.0_152]
at sun.net.www.http.HttpClient.(HttpClient.java:242) ~[?:1.8.0_152]
at sun.net.www.http.HttpClient.New(HttpClient.java:339) ~[?:1.8.0_152]
at sun.net.www.http.HttpClient.New(HttpClient.java:357) ~[?:1.8.0_152]
at sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1220) ~[?:1.8.0_152]
at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1156) ~[?:1.8.0_152]
at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1050) ~[?:1.8.0_152]
at sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:984) ~[?:1.8.0_152]
at com.netease.sloth.flink.connector.starrocks.manager.StarRocksStreamLoadVisitor.tryHttpConnection(StarRocksStreamLoadVisitor.java:245) ~[plugin_ne-flink-1.12.4-1.1.7_scala2.12_hive2.1.1-release-3.9.4-1.4.4.jar:?]
at com.netease.sloth.flink.connector.starrocks.manager.StarRocksStreamLoadVisitor.getAvailableHost(StarRocksStreamLoadVisitor.java:233) ~[plugin_ne-flink-1.12.4-1.1.7_scala2.12_hive2.1.1-release-3.9.4-1.4.4.jar:?]
at com.netease.sloth.flink.connector.starrocks.manager.StarRocksStreamLoadVisitor.doStreamLoad(StarRocksStreamLoadVisitor.java:82) ~[plugin_ne-flink-1.12.4-1.1.7_scala2.12_hive2.1.1-release-3.9.4-1.4.4.jar:?]
at com.netease.sloth.flink.connector.starrocks.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:444) ~[plugin_ne-flink-1.12.4-1.1.7_scala2.12_hive2.1.1-release-3.9.4-1.4.4.jar:?]
at com.netease.sloth.flink.connector.starrocks.manager.StarRocksSinkManager.lambda$startAsyncFlushing$0(StarRocksSinkManager.java:266) ~[plugin_ne-flink-1.12.4-1.1.7_scala2.12_hive2.1.1-release-3.9.4-1.4.4.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_152]