apache / apache/seatunnel

[Bug][Connector-v2] [Oracle-CDC] [Paimon][checkpoint] CheckpointCoordinator inside have error.

Open
#10,417 43 comments 0 reactions 1 assignee Claimed by @JeremyXin View on GitHub
bug
Dominant language
Java
Stars
9.7k
Forks
2.4k
Avg merge
3d 9h
Merged PRs (30d)
204

Description

### Search before asking

- [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues.

### What happened
分离集群 sea on ZATE引擎 2.3.12

oracle cdc 写入paimon , 测试 从保存点恢复失败 失败

### SeaTunnel Version

sea 2.3.12

### SeaTunnel Config

```conf
cat > /data/workspaces/sea_config_file/STREAMING-ZETA-ZG_ERP-ALL_TABLE.config </10.80.108.47:5801}, remoteAddress=[10.80.108.47]:5801, lastReadTime=2026-01-29 16:39:17.266, lastWriteTime=2026-01-29 16:39:09.270, closedTime=2026-01-29 16:39:17.271, connected server version=5.1}
2026-01-29 16:39:17,274 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.17]:5802:23d17ea5-7404-47ff-ad34-1a30af07567c, connection: ClientConnection{alive=false, connectionId=4, channel=NioChannel{/10.80.108.93:45139->/10.80.108.17:5802}, remoteAddress=[10.80.108.17]:5802, lastReadTime=2026-01-29 16:39:14.196, lastWriteTime=2026-01-29 16:39:14.196, closedTime=2026-01-29 16:39:17.273, connected server version=5.1}
2026-01-29 16:39:17,274 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.37]:5802:52b3715d-be8b-4437-820b-020092f3fb5c, connection: ClientConnection{alive=false, connectionId=3, channel=NioChannel{/10.80.108.93:51883->/10.80.108.37:5802}, remoteAddress=[10.80.108.37]:5802, lastReadTime=2026-01-29 16:39:09.196, lastWriteTime=2026-01-29 16:39:09.196, closedTime=2026-01-29 16:39:17.274, connected server version=5.1}
2026-01-29 16:39:17,275 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.75]:5801:6f0bc40b-edbf-4f0b-a615-df7d33f5a005, connection: ClientConnection{alive=false, connectionId=2, channel=NioChannel{/10.80.108.93:39149->/10.80.108.75:5801}, remoteAddress=[10.80.108.75]:5801, lastReadTime=2026-01-29 16:39:14.271, lastWriteTime=2026-01-29 16:39:14.270, closedTime=2026-01-29 16:39:17.275, connected server version=5.1}
2026-01-29 16:39:17,275 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [emrv3-seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED
2026-01-29 16:39:17,278 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [emrv3-seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN
2026-01-29 16:39:17,278 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client......
2026-01-29 16:39:17,278 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed metrics executor service ......
2026-01-29 16:39:17,278 ERROR [o.a.s.c.s.SeaTunnel ] [main] -

===============================================================================

2026-01-29 16:39:17,278 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error,

2026-01-29 16:39:17,278 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues

2026-01-29 16:39:17,278 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed

2026-01-29 16:39:17,279 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed
at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228)
at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:40)
Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: org.apache.seatunnel.engine.server.checkpoint.CheckpointException: CheckpointCoordinator inside have error.
at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.handleCoordinatorError(CheckpointCoordinator.java:282)
at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.handleCoordinatorError(CheckpointCoordinator.java:278)
at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:397)
at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:174)
at org.apache.seatunnel.engine.server.checkpoint.operation.CheckpointErrorReportOperation.runInternal(CheckpointErrorReportOperation.java:48)
at org.apache.seatunnel.engine.server.task.operation.TracingOperation.run(TracingOperation.java:42)
at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189)
at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:471)
at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:197)
at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:137)
at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123)
at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)
Caused by: org.apache.seatunnel.common.utils.SeaTunnelException: java.lang.NullPointerException
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.(PaimonSinkWriter.java:138)
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.(PaimonSinkWriter.java:188)
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSink.restoreWriter(PaimonSink.java:133)
at org.apache.seatunnel.api.sink.multitablesink.MultiTableSink.restoreWriter(MultiTableSink.java:115)
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.restoreState(SinkFlowLifeCycle.java:345)
at org.apache.seatunnel.engine.server.task.SeaTunnelTask.lambda$restoreState$16(SeaTunnelTask.java:401)
at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
at org.apache.seatunnel.engine.server.task.SeaTunnelTask.restoreState(SeaTunnelTask.java:398)
at org.apache.seatunnel.engine.server.checkpoint.operation.NotifyTaskRestoreOperation.lambda$null$0(NotifyTaskRestoreOperation.java:107)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1736)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)

... 12 more

at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220)
... 2 more
```

### Zeta or Flink or Spark Version

_No response_

### Java or Scala Version

_No response_

### Screenshots

_No response_

### Are you willing to submit PR?

- [ ] Yes I am willing to submit a PR!

### Code of Conduct

- [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.