fanxishu opened a new issue, #8219: URL: https://github.com/apache/seatunnel/issues/8219
### 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 我重启集群后发下提交集群的任务都是只会显示运行中然后结果就是执行的任务的表没有显示读取和写入记录。我改成混合集群模式就可以 After I restarted the cluster, I noticed that the tasks I submitted to the cluster were only showing as "Running" and the table with the executed tasks did not show any read or write records. -- `ABILITY`.product definition CREATE TABLE `product` ( `ID` int(10) NOT NULL COMMENT '主键', `NAME` varchar(50) DEFAULT NULL COMMENT '名称', `DESCRIPTION` varchar(512) DEFAULT NULL COMMENT '描述', `PRICE` decimal(10,2) DEFAULT NULL COMMENT '单价', `STOCK` int(10) DEFAULT NULL COMMENT '库存', `CREATE_DATE` datetime DEFAULT NULL COMMENT '创建时间', PRIMARY KEY (`ID`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='产品信息表'; ### SeaTunnel Version 2.3.8 ### SeaTunnel Config ```conf env { datasyncType=null scheduleConf=null "job.mode"=STREAMING "job.name"=fxspgtoteledb "checkpoint.interval"="30000" "savemode.execute.location"=CLUSTER } source { MySQL-CDC { format=DEFAULT "snapshot.split.size"="8096" "snapshot.fetch.size"="1024" "incremental.parallelism"="1" "connect.timeout.ms"="30000" "connect.max-retries"="3" "connection.pool.size"="20" "chunk-key.even-distribution.factor.lower-bound"="0.05" "chunk-key.even-distribution.factor.upper-bound"="100.0" "sample-sharding.threshold"="1000" "inverse-sampling.rate"="1000" "startup.mode"=INITIAL "exactly_once"="false" "stop.mode"=NEVER parallelism="1" "result_table_name"=Table15857388641664 "dag-parsing.mode"=MULTIPLEX catalog { factory=Mysql } database-names=[ "test_1" ] table-names=[ "test_1.product", "test_1.user" ] base-url="jdbc:mysql://127.0.0.1:8801/test_1?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true" username=test password="test@2023" server-time-zone=UTC } } transform { } sink { Jdbc { "schema_save_mode"="CREATE_SCHEMA_WHEN_NOT_EXIST" "data_save_mode"="APPEND_DATA" "create_index"="true" "connection_check_timeout_sec"="30" "batch_size"="1000" "is_exactly_once"="false" "max_commit_attempts"="3" "transaction_timeout_sec"="-1" "max_retries"="3" "auto_commit"="true" "support_upsert_by_query_primary_key_exist"="false" "multi_table_sink_replica"="1" "field_ide"=null "database_schema"=test "source_table_name"=Table15857388641664 "generate_sink_sql"=true catalog { factory=Postgres username=postgres password="test" base-url="jdbc:postgresql://127.0.0.1:5432/pgtest?useSSL=false&serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8" schema=test } database=pgtest user=postgres password="test" url="jdbc:postgresql://127.0.0.1:5432/pgtest?useSSL=false&serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8" driver="org.postgresql.Driver" } } ``` ### Running Command ```shell 2024-12-05 14:01:22,962 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-1] - Init JobMaster for Job 15865354423296_job (916932239512567809) 2024-12-05 14:01:22,962 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809) needed jar urls [file:/app01/seatuunel/a pache-seatunnel-2.3.8/connectors/connector-cdc-mysql-2.3.8.jar, file:/app01/seatuunel/apache-seatunnel-2.3.8/connectors/connector-jdbc-2.3.8.jar] 2024-12-05 14:01:22,964 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-1] - Create classloader for job 916932239512567809 with jars [file:/app01/seatuunel/apach e-seatunnel-2.3.8/connectors/connector-cdc-mysql-2.3.8.jar, file:/app01/seatuunel/apache-seatunnel-2.3.8/connectors/connector-jdbc-2.3.8.jar] 2024-12-05 14:01:23,416 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-1] - Catalog Postgres established connection to jdbc:postgresql://10.19.11.19:5432/pgtest ?useSSL=false&serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8 2024-12-05 14:01:23,417 INFO [a.s.a.s.SaveModeExecuteWrapper] [seatunnel-coordinator-service-1] - Executing save mode for table: pgtest.test.product, with SchemaSaveMode: CREATE_SCHE MA_WHEN_NOT_EXIST, DataSaveMode: APPEND_DATA using Catalog: Postgres 2024-12-05 14:01:23,433 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-1] - Catalog Postgres closing 2024-12-05 14:01:23,438 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-1] - Catalog Postgres established connection to jdbc:postgresql://10.19.11.19:5432/pgtest ?useSSL=false&serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8 2024-12-05 14:01:23,438 INFO [a.s.a.s.SaveModeExecuteWrapper] [seatunnel-coordinator-service-1] - Executing save mode for table: pgtest.test.user, with SchemaSaveMode: CREATE_SCHEMA_ WHEN_NOT_EXIST, DataSaveMode: APPEND_DATA using Catalog: Postgres 2024-12-05 14:01:23,441 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-1] - Catalog Postgres closing 2024-12-05 14:01:23,509 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-1] - Release classloader for job 916932239512567809 with jars [file:/app01/seatuunel/apac he-seatunnel-2.3.8/connectors/connector-cdc-mysql-2.3.8.jar, file:/app01/seatuunel/apache-seatunnel-2.3.8/connectors/connector-jdbc-2.3.8.jar] 2024-12-05 14:01:23,513 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-1] - recycle classloader for thread Timer-0 2024-12-05 14:01:23,744 WARN [o.a.h.u.NativeCodeLoader ] [seatunnel-coordinator-service-1] - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2024-12-05 14:01:23,875 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-1] - Create CheckpointCoordinator for job(1@916932239512567809) with plan(CheckpointPlan( pipelineId=1, pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}, TaskLocation{taskG roupLocation=TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=30000}, taskID=50000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=9169322395125 67809, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1} , taskID=20000, index=0}], pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Jdbc-Mul tiTableSink])=1}, subtaskActions={TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}=[(ActionStateKey( name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=30000}, taskID=50000 , index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Jdbc-MultiTableSink]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=916932239512567809, pipelineId =1, taskGroupId=1}, taskID=20000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-MySQL-CDC]), -1)]})) 2024-12-05 14:01:23,879 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - The task Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipe line-1 [Source[0]-MySQL-CDC]-SourceTask (1/1)] is in state CREATED when init state future 2024-12-05 14:01:23,880 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - The task Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipe line-1 [Source[0]-MySQL-CDC]-SplitEnumerator (1/1)] is in state CREATED when init state future 2024-12-05 14:01:23,881 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809) state process is start 2024-12-05 14:01:23,885 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809) turned from state CREATED to SCHEDULED. 2024-12-05 14:01:23,886 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)] state process is star t 2024-12-05 14:01:23,890 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)] turned from state CRE ATED to SCHEDULED. 2024-12-05 14:01:23,907 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)] turned from state SCH EDULED to DEPLOYING. 2024-12-05 14:01:23,908 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SplitEnumerator (1/1)] state process is start 2024-12-05 14:01:23,910 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SplitEnumerator (1/1)] turned from state CREATED to DEPLOYING. 2024-12-05 14:01:23,920 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-1] - [master-node-2]:5801 [seatunnel] [5.1] received deploying task executionId [91693224 8920391681] 2024-12-05 14:01:23,924 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-1] - Create classloader for job 916932239512567809 with jars [file:/app01/seatuunel/apach e-seatunnel-2.3.8/connectors/connector-cdc-mysql-2.3.8.jar] 2024-12-05 14:01:23,968 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-1] - [master-node-2]:5801 [seatunnel] [5.1] deploying task TaskGroupLocation{jobId=916932 239512567809, pipelineId=1, taskGroupId=1}, executionId [916932248920391681] 2024-12-05 14:01:23,968 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-1] - [master-node-2]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=9 16932239512567809, pipelineId=1, taskGroupId=1} init success 2024-12-05 14:01:23,973 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-1] - [master-node-2]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=9 16932239512567809, pipelineId=1, taskGroupId=1} success 2024-12-05 14:01:23,976 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - starting seatunnel source sp lit enumerator task, source name: pipeline-1 [Source[0]-MySQL-CDC] 2024-12-05 14:01:23,979 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SplitEnumerator (1/1)] turned from state DEPLOYING to RUNNING. 2024-12-05 14:01:23,980 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SplitEnumerator (1/1)] current state equals target state: RUNNING, skip 2024-12-05 14:01:23,980 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SourceTask (1/1)] state process is start 2024-12-05 14:01:23,984 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SourceTask (1/1)] turned from state CREATED to DEPLOYING. 2024-12-05 14:01:24,078 WARN [i.d.c.m.MySqlConnection ] [hz.main.seaTunnel.task.thread-2] - Database configuration option 'serverTimezone' is set but is obsolete, please use 'c onnectionTimeZone' instead 2024-12-05 14:01:24,203 INFO [.c.s.c.m.u.TableDiscoveryUtils] [hz.main.seaTunnel.task.thread-2] - Read list of available databases 2024-12-05 14:01:24,438 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SourceTask (1/1)] turned from state DEPLOYING to RUNNING. 2024-12-05 14:01:24,438 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)], task: [pipeline-1 [S ource[0]-MySQL-CDC]-SourceTask (1/1)] current state equals target state: RUNNING, skip 2024-12-05 14:01:24,451 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809), Pipeline: [(1/1)] turned from state DEP LOYING to RUNNING. 2024-12-05 14:01:24,508 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-1] - Job 15865354423296_job (916932239512567809) turned from state SCHEDULED to RUNNING. 2024-12-05 14:01:24,561 INFO [.c.s.c.m.u.TableDiscoveryUtils] [hz.main.seaTunnel.task.thread-2] - list of available databases is: [ability_1] 2024-12-05 14:01:24,561 INFO [.c.s.c.m.u.TableDiscoveryUtils] [hz.main.seaTunnel.task.thread-2] - Read list of available tables in each database 2024-12-05 14:01:24,583 INFO [i.d.j.JdbcConnection ] [pool-8-thread-1] - Connection gracefully closed 2024-12-05 14:01:24,585 WARN [i.d.c.m.MySqlConnection ] [hz.main.seaTunnel.task.thread-2] - Database configuration option 'serverTimezone' is set but is obsolete, please use 'c onnectionTimeZone' instead 2024-12-05 14:01:24,631 INFO [i.d.j.JdbcConnection ] [pool-9-thread-1] - Connection gracefully closed 2024-12-05 14:01:24,634 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.seaTunnel.task.thread-2] - SnapshotSplitAssigner created with remaining tables: [ability_1.product, ability_1.u ser] 2024-12-05 14:01:24,635 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.seaTunnel.task.thread-2] - SnapshotSplitAssigner created with remaining splits: [] 2024-12-05 14:01:24,635 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.seaTunnel.task.thread-2] - SnapshotSplitAssigner created with assigned splits: [] 2024-12-05 14:01:24,652 INFO [.s.t.SourceSplitEnumeratorTask] [hz.main.seaTunnel.task.thread-2] - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation {jobId=916932239512567809, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2024-12-05 14:01:24,750 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - checkpoint is enabled, start schedule trigger pending checkpoint. 2024-12-05 14:01:24,799 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - received enough reader, star ting enumerator... 2024-12-05 14:01:24,800 WARN [i.d.c.m.MySqlConnection ] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - Database configuration optio n 'serverTimezone' is set but is obsolete, please use 'connectionTimeZone' instead 2024-12-05 14:01:24,800 INFO [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - Start splitting table abilit y_1.product into chunks... 2024-12-05 14:01:25,971 INFO [.a.s.c.c.b.u.CatalogTableUtils] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - Override primary key([ID]) f or catalog table ability_1.product 2024-12-05 14:01:25,980 WARN [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - No unique key found for tabl e ability_1.product 2024-12-05 14:01:26,011 INFO [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - Splitting table ability_1.pr oduct into chunks, split column: ID, min: 1, max: 16, chunk size: 8096, distribution factor upper: 100.0, distribution factor lower: 0.05, sample sharding threshold: 1000 2024-12-05 14:01:26,015 INFO [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - The distribution factor of t able ability_1.product is 1.2308 according to the min split key 1, max split key 16 and approximate row count 13 2024-12-05 14:01:26,015 INFO [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - Use evenly-sized chunk optim ization for table ability_1.product, the approximate row count is 13, the chunk size is 8096, the dynamic chunk size is 9964 2024-12-05 14:01:26,016 INFO [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=916932239512567809, pipelineId=1, taskGroupId=1}] - Split table ability_1.produc t into 1 chunks, time cost: 1216ms. 2024-12-05 14:01:26,017 INFO [i.d.j.JdbcConnection ] [pool-10-thread-1] - Connection gracefully closed 2024-12-05 14:01:28,178 WARN [i.d.c.m.MySqlConnection ] [hz.main.generic-operation.thread-15] - Database configuration option 'serverTimezone' is set but is obsolete, please us e 'connectionTimeZone' instead 2024-12-05 14:01:28,178 INFO [bstractJdbcSourceChunkSplitter] [hz.main.generic-operation.thread-15] - Start splitting table ability_1.user into chunks... 2024-12-05 14:01:28,248 INFO [.a.s.c.c.b.u.CatalogTableUtils] [hz.main.generic-operation.thread-15] - Override primary key([id]) for catalog table ability_1.user 2024-12-05 14:01:28,250 WARN [bstractJdbcSourceChunkSplitter] [hz.main.generic-operation.thread-15] - No unique key found for table ability_1.user 2024-12-05 14:01:28,252 INFO [bstractJdbcSourceChunkSplitter] [hz.main.generic-operation.thread-15] - Splitting table ability_1.user into chunks, split column: id, min: 1, max: 13, c hunk size: 8096, distribution factor upper: 100.0, distribution factor lower: 0.05, sample sharding threshold: 1000 2024-12-05 14:01:28,256 INFO [bstractJdbcSourceChunkSplitter] [hz.main.generic-operation.thread-15] - The distribution factor of table ability_1.user is 2.1667 according to the min s plit key 1, max split key 13 and approximate row count 6 2024-12-05 14:01:28,256 INFO [bstractJdbcSourceChunkSplitter] [hz.main.generic-operation.thread-15] - Use evenly-sized chunk optimization for table ability_1.user, the approximate ro w count is 6, the chunk size is 8096, the dynamic chunk size is 17541 2024-12-05 14:01:28,256 INFO [bstractJdbcSourceChunkSplitter] [hz.main.generic-operation.thread-15] - Split table ability_1.user into 1 chunks, time cost: 78ms. 2024-12-05 14:01:28,261 INFO [i.d.j.JdbcConnection ] [pool-11-thread-1] - Connection gracefully closed 2024-12-05 14:01:28,872 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.generic-operation.thread-19] - Snapshot split assigner received all splits completed and the job parallelism is 1, snapshot split assigner is turn into completed status. 2024-12-05 14:01:28,893 INFO [.e.IncrementalSourceEnumerator] [hz.main.generic-operation.thread-22] - Clean the SnapshotSplitAssigner#assignedSplits/splitCompletedOffsets to empty. 2024-12-05 14:01:54,757 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 1 2024-12-05 14:01:54,931 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(1/1@916932239512567809) notify finished! 2024-12-05 14:01:54,931 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:1 2024-12-05 14:02:24,754 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 2 2024-12-05 14:02:24,778 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(2/1@916932239512567809) notify finished! 2024-12-05 14:02:24,778 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:2 2024-12-05 14:02:54,755 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 3 2024-12-05 14:02:54,776 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(3/1@916932239512567809) notify finished! 2024-12-05 14:02:54,776 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:3 2024-12-05 14:03:24,755 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 4 2024-12-05 14:03:24,773 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(4/1@916932239512567809) notify finished! 2024-12-05 14:03:24,773 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:4 2024-12-05 14:03:54,755 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 5 2024-12-05 14:03:54,770 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(5/1@916932239512567809) notify finished! 2024-12-05 14:03:54,770 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:5 2024-12-05 14:04:24,755 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 6 2024-12-05 14:04:24,770 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(6/1@916932239512567809) notify finished! 2024-12-05 14:04:24,770 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:6 2024-12-05 14:04:54,755 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 7 2024-12-05 14:04:54,769 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(7/1@916932239512567809) notify finished! 2024-12-05 14:04:54,769 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:7 2024-12-05 14:05:24,756 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 8 2024-12-05 14:05:24,772 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(8/1@916932239512567809) notify finished! 2024-12-05 14:05:24,772 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:8 2024-12-05 14:05:54,756 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 9 2024-12-05 14:05:54,770 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(9/1@916932239512567809) notify finished! 2024-12-05 14:05:54,770 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:9 2024-12-05 14:06:24,756 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - wait checkpoint completed: 10 2024-12-05 14:06:24,768 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - pending checkpoint(10/1@916932239512567809) notify finished! 2024-12-05 14:06:24,768 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-2] - start notify checkpoint completed, job id: 916932239512567809, pipeline id: 1, check point id:10 ``` ### Error Exception ```log 我重启集群后发下提交集群的任务都是只会显示运行中然后结果就是执行的任务的表没有显示读取和写入记录。 After I restarted the cluster, I noticed that the tasks I submitted to the cluster were only showing as "Running" and the table with the executed tasks did not show any read or write records. ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [X] 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
