jochenshen24 opened a new issue, #6013: URL: https://github.com/apache/seatunnel/issues/6013
### 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到mysql, source端数据没有数据时，报java.lang.NullPointerException异常; 确认用增量条件在源端查询时没有数据。 希望的结果是程序正常结束，统计数据中读写数据为0； 配置文件中增加partition_lower_bound和partition_upper_bound配置时达到希望的结果；但实际应用中不明确参数应该配置什么值 。 ### SeaTunnel Version 2.3.3 ### SeaTunnel Config ```conf env { execution.parallelism = 2 job.mode = "BATCH" } source { Jdbc { driver = "com.mysql.cj.jdbc.Driver" url = "jdbc:mysql://192.168.0.10:3306/test1?useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true" user = "username" password = "password" partition_column = "id" partition_num = 2 query = "select * from t_base where id>"${var}"" } } sink { Jdbc { driver = "com.mysql.cj.jdbc.Driver" url = "jdbc:mysql://192.168.0.32:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false" user = "username" password = "password" database = "test" table = "t_base" primary_keys = id support_upsert_by_query_primary_key_exist=true batch_size = 1000 connection_check_timeout_sec=30 generate_sink_sql=true } } ``` ### Running Command ```shell bin/seatunnel.sh --config /data/applications/seatunnel_data/mysql2mysql.config -m local -i var=2355 ``` ### Error Exception ```log 2023-12-15 17:35:28,597 INFO com.hazelcast.internal.diagnostics.Diagnostics - [localhost]:5801 [seatunnel-274994] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2023-12-15 17:35:28,605 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-274994] [5.1] [localhost]:5801 is STARTING 2023-12-15 17:35:28,651 INFO com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-274994] [5.1] [localhost]:5819 is added to the blacklist. 2023-12-15 17:35:29,666 INFO com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-274994] [5.1] 2023-12-15 17:35:31,638 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2023-12-15 17:35:31,692 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator... 2023-12-15 17:35:31,693 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits. 2023-12-15 17:35:31,693 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@68c9d5de java.lang.NullPointerException: null at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) [seatunnel-starter.jar:2.3.3] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_391] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_391] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_391] 2023-12-15 17:35:31,699 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} 2023-12-15 17:35:31,700 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} complete with state FAILED 2023-12-15 17:35:31,701 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-274994] [5.1] Received task end from execution TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1}, state FAILED 2023-12-15 17:35:31,703 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to end state FAILED. 2023-12-15 17:35:31,703 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] end with state FAILED and Exception: java.lang.NullPointerException at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) 2023-12-15 17:35:31,703 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} Failed in Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. 2023-12-15 17:35:31,703 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] count = 0 2023-12-15 17:35:31,704 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state RUNNING to CANCELING. 2023-12-15 17:35:31,705 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause Pipeline turn to end state. 2023-12-15 17:35:31,779 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state DEPLOYING to RUNNING. 2023-12-15 17:35:31,893 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2023-12-15 17:35:31,958 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator... 2023-12-15 17:35:31,958 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits. 2023-12-15 17:35:31,959 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@2783b289 java.lang.NullPointerException: null at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) [seatunnel-starter.jar:2.3.3] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_391] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_391] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_391] 2023-12-15 17:35:31,960 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} 2023-12-15 17:35:31,960 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} complete with state FAILED 2023-12-15 17:35:31,960 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-274994] [5.1] Received task end from execution TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1}, state FAILED 2023-12-15 17:35:31,962 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to end state FAILED. 2023-12-15 17:35:31,962 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] end with state FAILED and Exception: java.lang.NullPointerException at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) 2023-12-15 17:35:31,962 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} Failed in Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. 2023-12-15 17:35:31,962 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] count = 0 2023-12-15 17:35:32,204 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator... 2023-12-15 17:35:32,204 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits. 2023-12-15 17:35:32,205 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@1c3dffa0 java.lang.NullPointerException: null at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) [seatunnel-starter.jar:2.3.3] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_391] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_391] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_391] 2023-12-15 17:35:32,205 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} 2023-12-15 17:35:32,205 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} complete with state FAILED 2023-12-15 17:35:32,206 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-274994] [5.1] Received task end from execution TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1}, state FAILED 2023-12-15 17:35:32,206 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to end state FAILED. 2023-12-15 17:35:32,206 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] end with state FAILED and Exception: java.lang.NullPointerException at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) 2023-12-15 17:35:32,207 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} Failed in Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. 2023-12-15 17:35:32,207 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] count = 0 2023-12-15 17:35:32,207 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state RUNNING to CANCELING. 2023-12-15 17:35:32,208 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause Pipeline turn to end state. 2023-12-15 17:35:32,209 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_787976049127325697_1 state from RUNNING to CANCELED 2023-12-15 17:35:32,209 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to CANCELED 2023-12-15 17:35:32,209 WARN org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state in Imap is RUNNING, not equals expected state CREATED 2023-12-15 17:35:32,209 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to CANCELED 2023-12-15 17:35:32,209 WARN org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state in Imap is RUNNING, not equals expected state SCHEDULED 2023-12-15 17:35:32,209 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to CANCELED 2023-12-15 17:35:32,210 WARN org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state in Imap is RUNNING, not equals expected state DEPLOYING 2023-12-15 17:35:32,210 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from RUNNING to CANCELING 2023-12-15 17:35:32,210 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state RUNNING to CANCELING. 2023-12-15 17:35:32,212 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] operator to member [localhost]:5801 2023-12-15 17:35:32,212 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task (TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}) need cancel. 2023-12-15 17:35:32,212 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@78c1ec02 2023-12-15 17:35:32,212 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Interrupted task 50000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@1b6d6396 2023-12-15 17:35:32,212 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} 2023-12-15 17:35:32,212 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} 2023-12-15 17:35:32,212 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} complete with state CANCELED 2023-12-15 17:35:32,212 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-274994] [5.1] Received task end from execution TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}, state CANCELED 2023-12-15 17:35:32,213 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to end state CANCELED. 2023-12-15 17:35:32,213 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] end with state CANCELED 2023-12-15 17:35:32,213 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] end with state FAILED 2023-12-15 17:35:32,215 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn to end state FAILED. 2023-12-15 17:35:32,215 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Restore time 3, pipeline Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] 2023-12-15 17:35:32,215 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Reset pipeline Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] state to CREATED 2023-12-15 17:35:32,215 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Reset pipeline Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] state to CREATED complete 2023-12-15 17:35:32,216 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to state CREATED. 2023-12-15 17:35:32,217 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to state CREATED. 2023-12-15 17:35:32,217 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] is in state CREATED when init state future 2023-12-15 17:35:32,217 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] is in state CREATED when init state future 2023-12-15 17:35:32,217 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointManager - reported pipeline running stack: [java.lang.Thread.getStackTrace(Thread.java:1564), org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportedPipelineRunning(CheckpointManager.java:175), org.apache.seatunnel.engine.server.dag.physical.SubPlan.restorePipeline(SubPlan.java:579), org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$2(SubPlan.java:208), java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670), java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646), java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:750)] 2023-12-15 17:35:32,217 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - received restore CheckpointCoordinator with alreadyStarted= false 2023-12-15 17:35:32,218 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_787976049127325697_1 state from CANCELED to RUNNING 2023-12-15 17:35:32,218 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause CheckpointCoordinator reset. 2023-12-15 17:35:32,218 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state CREATED to SCHEDULED. 2023-12-15 17:35:32,219 INFO org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - received slot active check success, profile: SlotProfile{worker=[localhost]:5801, slotID=1, ownerJobID=787976049127325697, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='e8de8c4b-4c33-4446-ba1a-8e1ac0a9bafb'} 2023-12-15 17:35:32,219 INFO org.apache.seatunnel.engine.server.scheduler.PipelineBaseScheduler - use active old profile: SlotProfile{worker=[localhost]:5801, slotID=1, ownerJobID=787976049127325697, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='e8de8c4b-4c33-4446-ba1a-8e1ac0a9bafb'} for task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] 2023-12-15 17:35:32,219 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from CREATED to SCHEDULED 2023-12-15 17:35:32,220 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state CREATED to SCHEDULED. 2023-12-15 17:35:32,220 INFO org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - received slot active check success, profile: SlotProfile{worker=[localhost]:5801, slotID=2, ownerJobID=787976049127325697, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='e8de8c4b-4c33-4446-ba1a-8e1ac0a9bafb'} 2023-12-15 17:35:32,220 INFO org.apache.seatunnel.engine.server.scheduler.PipelineBaseScheduler - use active old profile: SlotProfile{worker=[localhost]:5801, slotID=2, ownerJobID=787976049127325697, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='e8de8c4b-4c33-4446-ba1a-8e1ac0a9bafb'} for task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] 2023-12-15 17:35:32,220 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to SCHEDULED 2023-12-15 17:35:32,220 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state CREATED to SCHEDULED. 2023-12-15 17:35:32,221 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state SCHEDULED to DEPLOYING. 2023-12-15 17:35:32,226 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from SCHEDULED to DEPLOYING 2023-12-15 17:35:32,227 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state SCHEDULED to DEPLOYING. 2023-12-15 17:35:32,227 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to DEPLOYING 2023-12-15 17:35:32,227 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement - PrepareStatement sql is: INSERT INTO `test`.`t_base` (`id`, `created_by`, `created_time`, `updated_by`, `updated_time`, `is_delete`, `district_code`, `name`, `sort`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE `id`=VALUES(`id`), `created_by`=VALUES(`created_by`), `created_time`=VALUES(`created_time`), `updated_by`=VALUES(`updated_by`), `updated_time`=VALUES(`updated_time`), `is_delete`=VALUES(`is_delete`), `district_code`=VALUES(`district_code`), `name`=VALUES(`name`), `sort`=VALUES(`sort`) 2023-12-15 17:35:32,227 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state SCHEDULED to DEPLOYING. 2023-12-15 17:35:32,228 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement - PrepareStatement sql is: DELETE FROM `test`.`t_base` WHERE `id` = ? 2023-12-15 17:35:32,228 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] received deploying task executionId [787976055175905281] 2023-12-15 17:35:32,231 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] received deploying task executionId [787976055175970817] 2023-12-15 17:35:32,243 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] deploying task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1}, executionId [787976055175970817] 2023-12-15 17:35:32,243 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] deploying TaskGroup TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} init success 2023-12-15 17:35:32,244 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] deploying task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}, executionId [787976055175905281] 2023-12-15 17:35:32,244 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] deploying TaskGroup TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} success 2023-12-15 17:35:32,244 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from DEPLOYING to RUNNING 2023-12-15 17:35:32,244 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] deploying TaskGroup TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} init success 2023-12-15 17:35:32,245 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc-default-identifier] 2023-12-15 17:35:32,248 INFO org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask - starting seatunnel transform task, index 0 2023-12-15 17:35:32,248 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] deploying TaskGroup TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} success 2023-12-15 17:35:32,248 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to RUNNING 2023-12-15 17:35:32,249 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state DEPLOYING to RUNNING. 2023-12-15 17:35:32,249 INFO org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask - starting seatunnel source task, index 0 2023-12-15 17:35:32,251 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state DEPLOYING to RUNNING. 2023-12-15 17:35:32,253 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state DEPLOYING to RUNNING. 2023-12-15 17:35:32,381 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2023-12-15 17:35:32,449 INFO org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator... 2023-12-15 17:35:32,449 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits. 2023-12-15 17:35:32,450 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@19ec4f73 java.lang.NullPointerException: null at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) ~[connector-jdbc-2.3.3.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) [seatunnel-starter.jar:2.3.3] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_391] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_391] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_391] 2023-12-15 17:35:32,451 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} 2023-12-15 17:35:32,451 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} complete with state FAILED 2023-12-15 17:35:32,451 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-274994] [5.1] Received task end from execution TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1}, state FAILED 2023-12-15 17:35:32,452 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to end state FAILED. 2023-12-15 17:35:32,452 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] end with state FAILED and Exception: java.lang.NullPointerException at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) 2023-12-15 17:35:32,452 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=1} Failed in Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline. 2023-12-15 17:35:32,452 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] count = 0 2023-12-15 17:35:32,453 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn from state RUNNING to CANCELING. 2023-12-15 17:35:32,453 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause Pipeline turn to end state. 2023-12-15 17:35:32,454 INFO org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_787976049127325697_1 state from RUNNING to CANCELED 2023-12-15 17:35:32,454 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to CANCELED 2023-12-15 17:35:32,454 WARN org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state in Imap is RUNNING, not equals expected state CREATED 2023-12-15 17:35:32,454 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to CANCELED 2023-12-15 17:35:32,454 WARN org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state in Imap is RUNNING, not equals expected state SCHEDULED 2023-12-15 17:35:32,454 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to CANCELED 2023-12-15 17:35:32,455 WARN org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state in Imap is RUNNING, not equals expected state DEPLOYING 2023-12-15 17:35:32,455 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from RUNNING to CANCELING 2023-12-15 17:35:32,455 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state RUNNING to CANCELING. 2023-12-15 17:35:32,456 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] operator to member [localhost]:5801 2023-12-15 17:35:32,456 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task (TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}) need cancel. 2023-12-15 17:35:32,457 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@3a2a3255 2023-12-15 17:35:32,457 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Interrupted task 50000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@31c72ce2 2023-12-15 17:35:32,457 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} 2023-12-15 17:35:32,457 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] taskDone, taskId = 50000, taskGroup = TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} 2023-12-15 17:35:32,457 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-274994] [5.1] Task TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000} complete with state CANCELED 2023-12-15 17:35:32,457 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-274994] [5.1] Received task end from execution TaskGroupLocation{jobId=787976049127325697, pipelineId=1, taskGroupId=30000}, state CANCELED 2023-12-15 17:35:32,458 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to end state CANCELED. 2023-12-15 17:35:32,458 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] end with state CANCELED 2023-12-15 17:35:32,458 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] end with state FAILED 2023-12-15 17:35:32,470 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement - PrepareStatement sql is: INSERT INTO `test`.`t_base` (`id`, `created_by`, `created_time`, `updated_by`, `updated_time`, `is_delete`, `district_code`, `name`, `sort`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE `id`=VALUES(`id`), `created_by`=VALUES(`created_by`), `created_time`=VALUES(`created_time`), `updated_by`=VALUES(`updated_by`), `updated_time`=VALUES(`updated_time`), `is_delete`=VALUES(`is_delete`), `district_code`=VALUES(`district_code`), `name`=VALUES(`name`), `sort`=VALUES(`sort`) 2023-12-15 17:35:32,471 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement - PrepareStatement sql is: DELETE FROM `test`.`t_base` WHERE `id` = ? 2023-12-15 17:35:32,491 INFO org.apache.seatunnel.engine.server.master.JobMaster - release the pipeline Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] resource 2023-12-15 17:35:32,492 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 787976049127325697, slot: SlotProfile{worker=[localhost]:5801, slotID=2, ownerJobID=787976049127325697, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='e8de8c4b-4c33-4446-ba1a-8e1ac0a9bafb'} 2023-12-15 17:35:32,492 INFO org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - received slot release request, jobID: 787976049127325697, slot: SlotProfile{worker=[localhost]:5801, slotID=1, ownerJobID=787976049127325697, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='e8de8c4b-4c33-4446-ba1a-8e1ac0a9bafb'} 2023-12-15 17:35:32,495 INFO org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] turn to end state FAILED. 2023-12-15 17:35:32,495 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - cancel job Job SeaTunnel_Job (787976049127325697) because makeJobEndWhenPipelineEnded is true 2023-12-15 17:35:32,496 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (787976049127325697) turn from state RUNNING to CANCELLING. 2023-12-15 17:35:32,498 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] count = 0 2023-12-15 17:35:32,498 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] is in end state FAILED, can not be cancel 2023-12-15 17:35:32,498 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Pipeline is trying to leave terminal state FAILED 2023-12-15 17:35:32,498 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (787976049127325697), Pipeline: [(1/1)] cancel error java.lang.IllegalStateException: Pipeline is trying to leave terminal state FAILED at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:348) ~[seatunnel-starter.jar:2.3.3] at org.apache.seatunnel.engine.server.dag.physical.SubPlan.cancelPipeline(SubPlan.java:414) ~[seatunnel-starter.jar:2.3.3] at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_391] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_391] 2023-12-15 17:35:32,499 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (787976049127325697) turn from state CANCELLING to FAILING. 2023-12-15 17:35:32,500 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job (787976049127325697) turn from state FAILING to FAILED. 2023-12-15 17:35:32,515 INFO org.apache.seatunnel.engine.client.job.ClientJobProxy - Job (787976049127325697) end with state FAILED 2023-12-15 17:35:32,516 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-274994] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN 2023-12-15 17:35:32,523 INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [localhost]:5801 [seatunnel-274994] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:51456, qualifier=null, endpoint=[127.0.0.1]:51456, remoteUuid=d137323d-bc3a-4c6c-924a-e484d4b5a932, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side 2023-12-15 17:35:32,524 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-274994] [5.1] Removed connection to endpoint: [localhost]:5801:8b75a117-5fa7-4120-bd2a-0f65821ce8a9, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:51456->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2023-12-15 17:35:32.514, lastWriteTime=2023-12-15 17:35:31.413, closedTime=2023-12-15 17:35:32.522, connected server version=5.1} 2023-12-15 17:35:32,524 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-274994] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2023-12-15 17:35:32,525 INFO com.hazelcast.client.impl.ClientEndpointManager - [localhost]:5801 [seatunnel-274994] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:51456, qualifier=null, endpoint=[127.0.0.1]:51456, remoteUuid=d137323d-bc3a-4c6c-924a-e484d4b5a932, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=d137323d-bc3a-4c6c-924a-e484d4b5a932, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1702632929809, latest clientAttributes=lastStatisticsCollectionTime=1702632929840,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1702632929800,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=5420077056,os.freePhysicalMemorySize=338153472,os.freeSwapSpaceSize=8455180288,os.maxFileDescriptorCount=4096,os.openFileDescriptorCount=53,os.processCpuTime=6720000000,os.systemLoadAverage=0.08,os.totalPhysicalMemorySize=8201261056,os.tota lSwapSpaceSize=8455712768,runtime.availableProcessors=5,runtime.freeMemory=974814856,runtime.maxMemory=1029177344,runtime.totalMemory=1029177344,runtime.uptime=3207,runtime.usedMemory=54362488, labels=[]} 2023-12-15 17:35:32,527 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-274994] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2023-12-15 17:35:32,527 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed SeaTunnel client...... 2023-12-15 17:35:32,527 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-274994] [5.1] [localhost]:5801 is SHUTTING_DOWN 2023-12-15 17:35:32,531 INFO com.hazelcast.internal.partition.impl.MigrationManager - [localhost]:5801 [seatunnel-274994] [5.1] Shutdown request of Member [localhost]:5801 - 8b75a117-5fa7-4120-bd2a-0f65821ce8a9 this is handled 2023-12-15 17:35:32,535 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-274994] [5.1] Shutting down connection manager... 2023-12-15 17:35:32,537 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-274994] [5.1] Shutting down node engine... 2023-12-15 17:35:35,554 INFO com.hazelcast.instance.impl.NodeExtension - [localhost]:5801 [seatunnel-274994] [5.1] Destroying node NodeExtension. 2023-12-15 17:35:35,554 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-274994] [5.1] Hazelcast Shutdown is completed in 3024 ms. 2023-12-15 17:35:35,555 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-274994] [5.1] [localhost]:5801 is SHUTDOWN 2023-12-15 17:35:35,555 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed HazelcastInstance ...... 2023-12-15 17:35:35,555 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed metrics executor service ...... 2023-12-15 17:35:35,555 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== 2023-12-15 17:35:35,555 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, 2023-12-15 17:35:35,555 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues 2023-12-15 17:35:35,555 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:SeaTunnel job executed failed 2023-12-15 17:35:35,557 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:191) 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.NullPointerException at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) at org.apache.seatunnel.engine.client.job.ClientJobProxy.waitForJobComplete(ClientJobProxy.java:122) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:184) ... 2 more 2023-12-15 17:35:35,557 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:191) 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.NullPointerException at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.split.JdbcNumericBetweenParametersProvider.<init>(JdbcNumericBetweenParametersProvider.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.discoverySplits(JdbcSourceSplitEnumerator.java:118) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator.run(JdbcSourceSplitEnumerator.java:87) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303) at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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) at org.apache.seatunnel.engine.client.job.ClientJobProxy.waitForJobComplete(ClientJobProxy.java:122) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:184) ... 2 more 2023-12-15 17:35:39,319 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - run shutdown hook because get close signal ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version java version "1.8.0_391" ### Screenshots <img width="1706" alt="image" src="https://github.com/apache/seatunnel/assets/105631880/d4b4a02d-63eb-414c-8331-dc57571794fc";> ### 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
