liusy-bd commented on issue #10417: URL: https://github.com/apache/seatunnel/issues/10417#issuecomment-3957376278
@JeremyXin Download link：https://codeload.github.com/apache/seatunnel/zip/refs/tags/2.3.13 I installed the cluster mode based on the latest Seatunnel 2.3.13 version and tested that the Oracle CDC writing to Paimon was normal. However, when restoring from the savepoint, the same error still occurred. command： ``` $SEATUNNEL_HOME/bin/seatunnel.sh -s 1078936991984254978 $SEATUNNEL_HOME/bin/seatunnel.sh \ -c /data/workspaces/sea_config_file/STREAMING-ZETA-ZG_ERP-ALL_TABLE.config \ -r 1078936991984254978 \ -n STREAMING-ZETA-ZG_ERP-ALL_TABLE ``` 2026-02-25 15:22:57,134 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Start submit job, job id: 1078936991984254978, with plugin jar [file:/data/seatunnel/connectors/connector-cdc-oracle-2.3.13.jar, file:/data/seatunnel/connectors/connector-cdc-base-2.3.13.jar, file:/data/seatunnel/connectors/connector-paimon-2.3.13.jar, file:/data/seatunnel/plugins/ojdbc8-23.26.0.0.0.jar, file:/data/seatunnel/plugins/orai18n-23.26.0.0.0.jar] 2026-02-25 15:22:57,438 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Submit job finished, job id: 1078936991984254978, job name: STREAMING-ZETA-ZG_ERP-ALL_TABLE 2026-02-25 15:22:57,474 WARN [o.a.s.e.c.j.JobMetricsRunner ] [job-metrics-runner-1078936991984254978] - Failed to get job metrics summary, it maybe first-run 2026-02-25 15:23:06,910 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Job (1078936991984254978) end with state FAILED 2026-02-25 15:23:06,911 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [emrv3-seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2026-02-25 15:23:06,914 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.75]:5801:9aac6657-bcea-48f7-a60f-253183fcfee4, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/10.80.108.93:43755->/10.80.108.75:5801}, remoteAddress=[10.80.108.75]:5801, lastReadTime=2026-02-25 15:23:06.907, lastWriteTime=2026-02-25 15:23:03.319, closedTime=2026-02-25 15:23:06.912, connected server version=5.1} 2026-02-25 15:23:06,915 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.17]:5802:bdd9a6da-fdc0-4848-84f6-74a723213cc9, connection: ClientConnection{alive=false, connectionId=3, channel=NioChannel{/10.80.108.93:37517->/10.80.108.17:5802}, remoteAddress=[10.80.108.17]:5802, lastReadTime=2026-02-25 15:23:03.244, lastWriteTime=2026-02-25 15:23:03.244, closedTime=2026-02-25 15:23:06.914, connected server version=5.1} 2026-02-25 15:23:06,916 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.37]:5802:97b6587f-6b5f-4b3a-8d82-cfc7da4b8736, connection: ClientConnection{alive=false, connectionId=4, channel=NioChannel{/10.80.108.93:33453->/10.80.108.37:5802}, remoteAddress=[10.80.108.37]:5802, lastReadTime=2026-02-25 15:22:58.321, lastWriteTime=2026-02-25 15:22:58.320, closedTime=2026-02-25 15:23:06.915, connected server version=5.1} 2026-02-25 15:23:06,916 INFO [.c.i.c.ClientConnectionManager] [main] - hz.client_1 [emrv3-seatunnel] [5.1] Removed connection to endpoint: [10.80.108.47]:5801:f65eddfc-8086-46a9-a722-9fd7ebc337b5, connection: ClientConnection{alive=false, connectionId=2, channel=NioChannel{/10.80.108.93:55833->/10.80.108.47:5801}, remoteAddress=[10.80.108.47]:5801, lastReadTime=2026-02-25 15:22:58.244, lastWriteTime=2026-02-25 15:22:58.244, closedTime=2026-02-25 15:23:06.916, connected server version=5.1} 2026-02-25 15:23:06,917 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [emrv3-seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2026-02-25 15:23:06,919 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [emrv3-seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2026-02-25 15:23:06,919 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2026-02-25 15:23:06,919 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed metrics executor service ...... 2026-02-25 15:23:06,919 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2026-02-25 15:23:06,920 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2026-02-25 15:23:06,920 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2026-02-25 15:23:06,920 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2026-02-25 15:23:06,921 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:266) 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:289) at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.handleCoordinatorError(CheckpointCoordinator.java:285) at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:405) at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:183) 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.<init>(PaimonSinkWriter.java:143) at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.<init>(PaimonSinkWriter.java:196) at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSink.restoreWriter(PaimonSink.java:156) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSink.restoreWriter(MultiTableSink.java:115) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.restoreState(SinkFlowLifeCycle.java:348) 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$runInternal$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:258) ... 2 more 2026-02-25 15:23:06,921 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:266) 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:289) at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.handleCoordinatorError(CheckpointCoordinator.java:285) at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:405) at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:183) 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.<init>(PaimonSinkWriter.java:143) at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.<init>(PaimonSinkWriter.java:196) at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSink.restoreWriter(PaimonSink.java:156) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSink.restoreWriter(MultiTableSink.java:115) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.restoreState(SinkFlowLifeCycle.java:348) 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$runInternal$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:258) ... 2 more 2026-02-25 15:23:06,923 INFO [s.c.s.s.c.ClientExecuteCommand] [SeaTunnel-CompletableFuture-Thread-0] - run shutdown hook because get close signal -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
