使用Flink CDC 无法连接服务器，但是网络畅通

天下第一帅 · 2023 年3 月 31 日 03:00

为提高效率，请提供以下信息，问题描述清晰能够更快得到解决：

【概述】场景 + 问题概述

【应用框架及开发适配业务逻辑】
依赖包：

Flink 版本 1.14.4

<dependency>
			<groupId>com.ververica</groupId>
			<artifactId>flink-connector-tidb-cdc</artifactId>
			<!-- The dependency is available only for stable releases, SNAPSHOT dependency need build by yourself. -->
			<version>2.2.0</version>
		</dependency>

【背景】做过哪些操作

【现象】业务和数据库现象

提示
使用Flink CDC的 tidb，连接发现如下错误：
10:56:25,283 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,283 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,284 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,284 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,323 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,324 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,325 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,326 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,328 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,328 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,328 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable
10:56:25,329 WARN org.tikv.common.region.StoreHealthyChecker [] - store [tidb-default-tikv-0.tidb-default-tikv-peer.component.svc:20160] is not reachable

org.tikv.shade.io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 4.999980801s. [remote_addr=tidb-default-pd-0.tidb-default-pd-peer.component.svc/10.224.2.64:2379]
但是telnet是可以联通的，网络没有任何问题。

org.tikv.shade.io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: deadline exceeded after 4.999962518s. [remote_addr=tidb-default-pd-0.tidb-default-pd-peer.component.svc/10.224.2.64:2379]
	at org.tikv.shade.io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:287) ~[tikv-client-java-3.2.0.jar:?]
	at org.tikv.shade.io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:268) ~[tikv-client-java-3.2.0.jar:?]
	at org.tikv.shade.io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:175) ~[tikv-client-java-3.2.0.jar:?]
	at org.tikv.kvproto.PDGrpc$PDBlockingStub.getMembers(PDGrpc.java:1868) ~[tikv-client-java-3.2.0.jar:?]
	at org.tikv.common.PDClient.getMembers(PDClient.java:443) ~[tikv-client-java-3.2.0.jar:?]
	at org.tikv.common.PDClient.tryUpdateLeader(PDClient.java:565) ~[tikv-client-java-3.2.0.jar:?]
	at org.tikv.common.PDClient.lambda$initCluster$15(PDClient.java:730) ~[tikv-client-java-3.2.0.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_291]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_291]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_291]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_291]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_291]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_291]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_291]

请教下。是不是TiDB还要什么操作，安装什么服务？

【问题】当前遇到的问题

【业务影响】

【TiDB 版本】

【附件】相关日志及监控