FvkinSKy opened a new issue, #8846: URL: https://github.com/apache/seatunnel/issues/8846
### 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 MySQL environment configuration is as follows: version: 8.0.41 ```sql show variables where variable_name in ('log_bin', 'binlog_format', 'binlog_row_image', 'gtid_mode', 'enforce_gtid_consistency') ```  my.cnf  When I run CDC using SeaTunnel in local mode, an error occurs：Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: java.lang.NoSuchMethodError: org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()Z I noticed that two other articles mentioned the same issue. Is there a plan to fix it? https://github.com/apache/seatunnel/issues/7455 https://github.com/apache/seatunnel/issues/8055 ### SeaTunnel Version 2.3.9 ### SeaTunnel Config ```conf env { parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 10000 } source { MySQL-CDC { base-url = "jdbc:mysql://127.0.0.1:3306/datasource_test" username = "root" password = "root@123" table-names = ["datasource_test.datamodel"] startup.mode = "initial" } } sink { Console { } } ``` ### Running Command ```shell .\seatunnel.cmd --config ./config/mysql_cdc_test.template -m local ``` ### Error Exception ```log [947038640234561537] 2025-02-26 15:53:40,246 INFO org.apache.seatunnel.connectors.cdc.base.source.enumerator.splitter.AbstractJdbcSourceChunkSplitter - The distribution factor of table datasource_test.datamodel is 1.15292150460684698E18 according to the min split key 1ac4b46415af4c598d626724b7dc50a9, max split key e4001259cf0d4108a09ed474594eb3de and approximate row count 8 [947038640234561537] 2025-02-26 15:53:40,246 INFO org.apache.seatunnel.connectors.cdc.base.source.enumerator.splitter.AbstractJdbcSourceChunkSplitter - Use unevenly-sized chunks for table datasource_test.datamodel, the chunk size is 8096 [947038640234561537] 2025-02-26 15:53:40,248 INFO org.apache.seatunnel.connectors.cdc.base.source.enumerator.splitter.AbstractJdbcSourceChunkSplitter - Split table datasource_test.datamodel into 1 chunks, time cost: 31ms. [947038640234561537] 2025-02-26 15:53:40,251 INFO io.debezium.jdbc.JdbcConnection - Connection gracefully closed [947038640234561537] 2025-02-26 15:53:40,251 INFO org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader - subtask 0 add splits: datasource_test.datamodel:0 [947038640234561537] 2025-02-26 15:53:40,252 INFO org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher - Starting split fetcher 0 [947038640234561537] 2025-02-26 15:53:40,252 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@75d50d1a java.lang.NoSuchMethodError: 'boolean org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()' at org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:115) ~[connector-cdc-mysql-2.3.9.jar:2.3.9] at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) ~[seatunnel-starter.jar:2.3.9] at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) ~[seatunnel-starter.jar:2.3.9] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) ~[seatunnel-starter.jar:2.3.9] at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) ~[seatunnel-starter.jar:2.3.9] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) [seatunnel-starter.jar:2.3.9] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) [seatunnel-starter.jar:2.3.9] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) [seatunnel-starter.jar:2.3.9] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:829) [?:?] [947038640234561537] 2025-02-26 15:53:40,252 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000} [947038640234561537] 2025-02-26 15:53:40,252 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] task 40000 error with exception: [java.lang.NoSuchMethodError: 'boolean org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()'], cancel other task in taskGroup TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000}. [947038640234561537] 2025-02-26 15:53:40,252 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] Interrupted task 50000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@1151464d [947038640234561537] 2025-02-26 15:53:40,252 INFO org.apache.kafka.connect.json.JsonConverterConfig - JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [947038640234561537] 2025-02-26 15:53:40,253 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000} [947038640234561537] 2025-02-26 15:53:40,253 INFO org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase - Closing Source Reader. [] 2025-02-26 15:53:40,253 INFO org.apache.seatunnel.api.event.LoggingEventHandler - log event: ReaderCloseEvent(createdTime=1740556420253, jobId=947038640234561537, eventType=LIFECYCLE_READER_CLOSE) [947038640234561537] 2025-02-26 15:53:40,253 INFO org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher - Shutting down split fetcher 0 [947038640234561537] 2025-02-26 15:53:40,253 WARN io.debezium.connector.mysql.MySqlConnection - Database configuration option 'serverTimezone' is set but is obsolete, please use 'connectionTimeZone' instead [947038640234561537] 2025-02-26 15:53:40,255 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] taskGroup TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000} complete with FAILED [947038640234561537] 2025-02-26 15:53:40,256 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] task 50000 error with exception: [java.lang.NoSuchMethodError: 'boolean org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()'], cancel other task in taskGroup TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000}. [947038640234561537] 2025-02-26 15:53:40,256 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] Task TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000} complete with state FAILED [947038640234561537] 2025-02-26 15:53:40,257 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-645986] [5.1] Received task end from execution TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000}, state FAILED [] 2025-02-26 15:53:40,257 INFO org.apache.seatunnel.api.event.LoggingEventHandler - log event: WriterCloseEvent(createdTime=1740556420256, jobId=947038640234561537, eventType=LIFECYCLE_WRITER_CLOSE) [947038640234561537] 2025-02-26 15:53:40,257 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)] turned from state RUNNING to FAILED. [947038640234561537] 2025-02-26 15:53:40,258 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)] state process is stopped [947038640234561537] 2025-02-26 15:53:40,258 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)] end with state FAILED and Exception: java.lang.NoSuchMethodError: 'boolean org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()' at org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:115) at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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) [947038640234561537] 2025-02-26 15:53:40,258 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)] future complete with state FAILED [947038640234561537] 2025-02-26 15:53:40,258 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000} Failed in Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. [947038640234561537] 2025-02-26 15:53:40,258 INFO org.apache.seatunnel.engine.server.master.JobMaster - release the task group resource TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=30000} [947038640234561537] 2025-02-26 15:53:40,258 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 947038640234561537, slot: SlotProfile{worker=[localhost]:5801, slotID=8, ownerJobID=947038640234561537, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='055e38f2-de88-40ce-9e77-56f3d850b5ab'} [947038640234561537] 2025-02-26 15:53:40,259 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)] turned from state RUNNING to FAILING. [947038640234561537] 2025-02-26 15:53:40,259 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] state process is start [947038640234561537] 2025-02-26 15:53:40,260 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] turned from state RUNNING to CANCELING. [947038640234561537] 2025-02-26 15:53:40,260 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] operator to member [localhost]:5801 [947038640234561537] 2025-02-26 15:53:40,260 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] Task (TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=1}) need cancel. [947038640234561537] 2025-02-26 15:53:40,260 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)] state process is start [947038640234561537] 2025-02-26 15:53:40,260 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] Interrupted task 20000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@2b5cd2c7 [947038640234561537] 2025-02-26 15:53:40,261 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=1} [947038640234561537] 2025-02-26 15:53:40,262 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] taskGroup TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=1} complete with CANCELED [947038640234561537] 2025-02-26 15:53:40,262 INFO org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator - Closing enumerator... [947038640234561537] 2025-02-26 15:53:40,262 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-645986] [5.1] Task TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=1} complete with state CANCELED [947038640234561537] 2025-02-26 15:53:40,262 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-645986] [5.1] Received task end from execution TaskGroupLocation{jobId=947038640234561537, pipelineId=1, taskGroupId=1}, state CANCELED [] 2025-02-26 15:53:40,262 INFO org.apache.seatunnel.api.event.LoggingEventHandler - log event: EnumeratorCloseEvent(createdTime=1740556420262, jobId=947038640234561537, eventType=LIFECYCLE_ENUMERATOR_CLOSE) [947038640234561537] 2025-02-26 15:53:40,263 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] turned from state CANCELING to CANCELED. [947038640234561537] 2025-02-26 15:53:40,263 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] state process is stopped [947038640234561537] 2025-02-26 15:53:40,264 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] future complete with state CANCELED [947038640234561537] 2025-02-26 15:53:40,264 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause Pipeline turn to end state. [947038640234561537] 2025-02-26 15:53:40,264 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_947038640234561537_1 state from RUNNING to CANCELED [947038640234561537] 2025-02-26 15:53:40,264 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)] will end with state FAILED [947038640234561537] 2025-02-26 15:53:40,265 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)] turned from state FAILING to FAILED. [947038640234561537] 2025-02-26 15:53:40,275 INFO org.apache.seatunnel.connectors.cdc.base.utils.CatalogTableUtils - Override primary key([id]) for catalog table datasource_test.datamodel [947038640234561537] 2025-02-26 15:53:40,282 INFO org.apache.seatunnel.connectors.cdc.base.source.reader.external.IncrementalSourceScanFetcher - Start snapshot read task for snapshot split: SnapshotSplit(tableId=datasource_test.datamodel, splitKeyType=ROW<id STRING>, splitStart=null, splitEnd=null, lowWatermark=null, highWatermark=null) exactly-once: false [947038640234561537] 2025-02-26 15:53:40,286 INFO org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.scan.MySqlSnapshotSplitReadTask - Snapshot step 1 - Determining low watermark {ts_sec=0, file=binlog.000003, pos=157, gtids=, row=0, event=0} for split SnapshotSplit(tableId=datasource_test.datamodel, splitKeyType=ROW<id STRING>, splitStart=null, splitEnd=null, lowWatermark=null, highWatermark=null) [947038640234561537] 2025-02-26 15:53:40,286 INFO org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.scan.MySqlSnapshotSplitReadTask - Snapshot step 2 - Snapshotting data [947038640234561537] 2025-02-26 15:53:40,286 INFO org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.scan.MySqlSnapshotSplitReadTask - Exporting data from split 'datasource_test.datamodel:0' of table datasource_test.datamodel [947038640234561537] 2025-02-26 15:53:40,286 INFO org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.scan.MySqlSnapshotSplitReadTask - For split 'datasource_test.datamodel:0' of table datasource_test.datamodel using select statement: 'SELECT * FROM `datasource_test`.`datamodel`' [947038640234561537] 2025-02-26 15:53:40,292 INFO org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.scan.MySqlSnapshotSplitReadTask - Finished exporting 8 records for split 'datasource_test.datamodel:0', total duration '00:00:00.006' [947038640234561537] 2025-02-26 15:53:40,294 INFO org.apache.seatunnel.connectors.seatunnel.cdc.mysql.source.reader.fetch.scan.MySqlSnapshotSplitReadTask - Snapshot step 3 - Determining high watermark {ts_sec=0, file=binlog.000003, pos=157, gtids=, row=0, event=0} for split SnapshotSplit(tableId=datasource_test.datamodel, splitKeyType=ROW<id STRING>, splitStart=null, splitEnd=null, lowWatermark=null, highWatermark=null) [947038640234561537] 2025-02-26 15:53:40,329 INFO org.apache.seatunnel.engine.server.master.JobMaster - release the pipeline Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)] resource [947038640234561537] 2025-02-26 15:53:40,330 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 947038640234561537, slot: SlotProfile{worker=[localhost]:5801, slotID=7, ownerJobID=947038640234561537, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='055e38f2-de88-40ce-9e77-56f3d850b5ab'} [947038640234561537] 2025-02-26 15:53:40,330 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)] state process is stop [947038640234561537] 2025-02-26 15:53:40,330 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (947038640234561537), Pipeline: [(1/1)] future complete with state FAILED [947038640234561537] 2025-02-26 15:53:40,331 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - cancel job Job SeaTunnel_Job (947038640234561537) because makeJobEndWhenPipelineEnded is true [947038640234561537] 2025-02-26 15:53:40,331 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (947038640234561537) turned from state RUNNING to FAILING. [947038640234561537] 2025-02-26 15:53:40,333 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (947038640234561537) turned from state FAILING to FAILED. [947038640234561537] 2025-02-26 15:53:40,333 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (947038640234561537) state process is stop [] 2025-02-26 15:53:40,367 INFO org.apache.seatunnel.engine.client.job.ClientJobProxy - Job (947038640234561537) end with state FAILED [] 2025-02-26 15:53:40,368 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-645986] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN [] 2025-02-26 15:53:40,372 INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [localhost]:5801 [seatunnel-645986] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:55305, qualifier=null, endpoint=[127.0.0.1]:55305, remoteUuid=e58435e1-02fd-40a1-89bb-5b023d94ea08, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side [] 2025-02-26 15:53:40,372 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-645986] [5.1] Removed connection to endpoint: [localhost]:5801:94fa7a31-c390-4fac-a6a4-1000895242bf, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:55305->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2025-02-26 15:53:40.365, lastWriteTime=2025-02-26 15:53:36.914, closedTime=2025-02-26 15:53:40.369, connected server version=5.1} [] 2025-02-26 15:53:40,373 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-645986] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED [] 2025-02-26 15:53:40,376 INFO com.hazelcast.client.impl.ClientEndpointManager - [localhost]:5801 [seatunnel-645986] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:55305, qualifier=null, endpoint=[127.0.0.1]:55305, remoteUuid=e58435e1-02fd-40a1-89bb-5b023d94ea08, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=e58435e1-02fd-40a1-89bb-5b023d94ea08, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1740556406860, latest clientAttributes=lastStatisticsCollectionTime=1740556416910,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1740556406843,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=0,os.freePhysicalMemorySize=0,os.freeSwapSpaceSize=0,os.maxFileDescriptorCount=0,os.openFileDescriptorCount=0,os.processCpuTime=0,os.systemLoadAverage=-1.0,os.totalPhysicalMemorySize=0,os.totalSwapSpaceSize=0,runtime.availableProcessors= 16,runtime.freeMemory=116782040,runtime.maxMemory=536870912,runtime.totalMemory=268435456,runtime.uptime=21931,runtime.usedMemory=151653416, labels=[]} [] 2025-02-26 15:53:40,386 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-645986] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN [] 2025-02-26 15:53:40,386 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed SeaTunnel client...... [] 2025-02-26 15:53:40,386 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-645986] [5.1] [localhost]:5801 is SHUTTING_DOWN [] 2025-02-26 15:53:40,389 INFO com.hazelcast.internal.partition.impl.MigrationManager - [localhost]:5801 [seatunnel-645986] [5.1] Shutdown request of Member [localhost]:5801 - 94fa7a31-c390-4fac-a6a4-1000895242bf [master node] [active master] this is handled [] 2025-02-26 15:53:40,393 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-645986] [5.1] Shutting down connection manager... [] 2025-02-26 15:53:40,396 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-645986] [5.1] Shutting down node engine... [] 2025-02-26 15:53:40,410 INFO org.apache.seatunnel.shade.org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@21f7e537{HTTP/1.1, (http/1.1)}{0.0.0.0:8080} [] 2025-02-26 15:53:40,410 INFO org.apache.seatunnel.shade.org.eclipse.jetty.server.session - node0 Stopped scavenging [] 2025-02-26 15:53:40,413 INFO org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler - Stopped o.a.s.s.o.e.j.s.ServletContextHandler@14b8a751{/,null,STOPPED} [] 2025-02-26 15:53:40,415 INFO org.apache.seatunnel.engine.core.classloader.DefaultClassLoaderService - close classloader service [] 2025-02-26 15:53:40,416 INFO org.apache.seatunnel.engine.server.EventService - Event forward thread interrupted [] 2025-02-26 15:53:40,430 INFO com.hazelcast.instance.impl.NodeExtension - [localhost]:5801 [seatunnel-645986] [5.1] Destroying node NodeExtension. [] 2025-02-26 15:53:40,430 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-645986] [5.1] Hazelcast Shutdown is completed in 41 ms. [] 2025-02-26 15:53:40,431 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-645986] [5.1] [localhost]:5801 is SHUTDOWN [] 2025-02-26 15:53:40,431 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed HazelcastInstance ...... [] 2025-02-26 15:53:40,431 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed metrics executor service ...... [] 2025-02-26 15:53:40,431 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== [] 2025-02-26 15:53:40,431 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, [] 2025-02-26 15:53:40,431 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues [] 2025-02-26 15:53:40,431 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:SeaTunnel job executed failed [] 2025-02-26 15:53:40,432 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 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:34) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: java.lang.NoSuchMethodError: 'boolean org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()' at org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:115) at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ... 2 more [] 2025-02-26 15:53:40,432 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== 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:228) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: java.lang.NoSuchMethodError: 'boolean org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.isNoMoreSplitsAssignment()' at org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:115) at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:169) at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1019) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ... 2 more [947038640234561537] 2025-02-26 15:53:40,796 INFO org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceSplitReader - Close current fetcher org.apache.seatunnel.connectors.cdc.base.source.reader.external.IncrementalSourceScanFetcher [947038640234561537] 2025-02-26 15:53:40,801 INFO io.debezium.jdbc.JdbcConnection - Connection gracefully closed [947038640234561537] 2025-02-26 15:53:40,801 INFO org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher - Split fetcher 0 exited. [] 2025-02-26 15:53:40,804 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - run shutdown hook because get close signal ``` ### Zeta or Flink or Spark Version zeta ### Java or Scala Version java 11 ### Screenshots  ### 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) -- 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: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
