leonardBang commented on PR #3940:
URL: https://github.com/apache/flink-cdc/pull/3940#issuecomment-2703832804
After some investigation, we sure the failed case is due to CDC component of
Polardbx is not ready.
```
2025-03-06 11:28:30.740 [record-binlog-thread] ERROR
c.a.p.b.d.d.l.BinlogRecorderListener - on start failed
2025-03-06 11:28:44.501 [grpc-default-executor-1] ERROR
c.a.p.b.d.dump.logfile.LogFileReader - BinlogDump fail binlog.000001,4 null
```
```
2025-03-06 11:46:13.265 [grpc-default-executor-0] INFO
c.a.polardbx.binlog.dumper.CdcServer - dump binlog.000001 42025-03-06
11:46:13.267 [grpc-default-executor-0] INFO
c.a.p.b.d.dump.logfile.LogFileReader - binlogDump from
binlog.000001@42025-03-06 11:46:13.307 [grpc-default-executor-0] ERROR
c.a.p.b.d.dump.logfile.LogFileReader - BinlogDump fail binlog.000001,4 null
java.lang.NullPointerException: null
at
com.aliyun.polardbx.binlog.dumper.dump.logfile.BinlogDumpReader.valid(BinlogDumpReader.java:71)
at
com.aliyun.polardbx.binlog.dumper.dump.logfile.LogFileReader.binlogDump(LogFileReader.java:97)
at
com.aliyun.polardbx.binlog.dumper.CdcServer$1.dump(CdcServer.java:143)
at
com.aliyun.polardbx.rpc.cdc.CdcServiceGrpc$MethodHandlers.invoke(CdcServiceGrpc.java:905)
at
io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:172)
at
io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:331)
at
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:820)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Mar 06, 2025 11:46:13 AM io.grpc.internal.SerializingExecutor runSEVERE:
Exception while executing runnable
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed@55f6cd8f
java.lang.IllegalStateException: call already closed
at
com.google.common.base.Preconditions.checkState(Preconditions.java:508)
at
io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:209)
at io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:202)
at
io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onError(ServerCalls.java:360)
at
com.aliyun.polardbx.binlog.dumper.dump.logfile.LogFileReader.binlogDump(LogFileReader.java:145)
at
com.aliyun.polardbx.binlog.dumper.CdcServer$1.dump(CdcServer.java:143)
at
com.aliyun.polardbx.rpc.cdc.CdcServiceGrpc$MethodHandlers.invoke(CdcServiceGrpc.java:905)
at
io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:172)
at
io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:331)
at
io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:820)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
