[Bug] [Connector-Paimon] sink paimon java.lang.OutOfMemoryError: Java heap space

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened
source:oracle
sink:paimon
sink paimon java.lang.OutOfMemoryError: Java heap space
SeaTunnel Version
2.3.3
SeaTunnel Config
env {
  execution.parallelism = 1
  job.mode = "BATCH"
}

source {
  Jdbc {
        url = "jdbc:oracle:thin:@******:1521/WFLDBDEV"
        driver = "oracle.jdbc.OracleDriver"
        user = "biods"
        password = "******"
        query = "SELECT * FROM BIODS.EKKN"
    }
}

sink {
  Paimon {
    warehouse = "hdfs://******:9820/paimon"
    database = "biods"
    table = "ekkn"
  }
}

Running Command
./seatunnel.sh --config ../config/v2.batch.config.template -e local

Error Exception
2023-09-07 11:13:03,608 INFO  org.apache.seatunnel.core.starter.utils.ConfigShadeUtils - Load config shade spi: [base64]
2023-09-07 11:13:03,650 INFO  org.apache.seatunnel.core.starter.utils.ConfigBuilder - Parsed config file: {
    "env" : {
        "execution.parallelism" : 1,
        "job.mode" : "BATCH"
    },
    "source" : [
        {
            "password" : "******",
            "driver" : "oracle.jdbc.OracleDriver",
            "query" : "SELECT * FROM BIODS.EKKN",
            "plugin_name" : "Jdbc",
            "user" : "biods",
            "url" : "jdbc:oracle:thin:@******:1521/WFLDBDEV"
        }
    ],
    "sink" : [
        {
            "database" : "biods",
            "warehouse" : "hdfs://******:9820/paimon",
            "plugin_name" : "Paimon",
            "table" : "ekkn"
        }
    ]
}

2023-09-07 11:13:03,672 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-07 11:13:03,672 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-07 11:13:03,676 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /opt/apache-seatunnel-2.3.3/connectors/seatunnel
2023-09-07 11:13:03,680 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Jdbc at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar
2023-09-07 11:13:03,681 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Paimon at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar
2023-09-07 11:13:03,684 INFO  org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sources.
2023-09-07 11:13:03,685 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-07 11:13:03,703 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-07 11:13:03,705 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSource Plugin from /opt/apache-seatunnel-2.3.3/connectors/seatunnel
2023-09-07 11:13:03,712 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Jdbc at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar
2023-09-07 11:13:03,717 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} from classpath
2023-09-07 11:13:04,132 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-748082] [5.1] This node become a new active master node, begin init coordinator service
2023-09-07 11:13:04,170 INFO  com.hazelcast.internal.partition.impl.PartitionStateManager - [localhost]:5801 [seatunnel-748082] [5.1] Initializing cluster partition table arrangement...
2023-09-07 11:13:04,474 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource - The partition_column parameter is not configured, and the source parallelism is set to 1
2023-09-07 11:13:04,509 INFO  org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all transforms.
2023-09-07 11:13:04,509 INFO  org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sinks.
2023-09-07 11:13:04,510 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-07 11:13:04,514 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /opt/apache-seatunnel-2.3.3/connectors/seatunnel
2023-09-07 11:13:04,515 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Paimon at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar
2023-09-07 11:13:04,517 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Paimon'} from classpath
2023-09-07 11:13:04,669 WARN  org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2023-09-07 11:13:05,608 INFO  org.apache.seatunnel.engine.client.job.ClientJobProxy - Start submit job, job id:<PHONE_NUMBER>54293505, with plugin jar [file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar, file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar]
2023-09-07 11:13:05,619 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - Init ResourceManager
2023-09-07 11:13:05,619 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - initWorker...
2023-09-07 11:13:05,619 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - initWorker live nodes: [[localhost]:5801]
2023-09-07 11:13:05,620 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - registerWorker: {[localhost]:5801=WorkerProfile(address=[localhost]:5801, profile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=1029177344}}, unassignedResource=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=1029177344}}, assignedSlots=[], unassignedSlots=[])}
2023-09-07 11:13:05,640 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Init JobMaster for Job SeaTunnel_Job<PHONE_NUMBER>54293505)
2023-09-07 11:13:05,640 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Job SeaTunnel_Job<PHONE_NUMBER>54293505) needed jar urls [file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar, file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar]
2023-09-07 11:13:05,819 INFO  org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage - Path /tmp/seatunnel/checkpoint_snapshot/752003406054293505 is not a directory
2023-09-07 11:13:05,819 INFO  org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage - No checkpoint found for job, job id is:<PHONE_NUMBER>54293505
2023-09-07 11:13:05,822 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] is in state CREATED when init state future
2023-09-07 11:13:05,823 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] is in state CREATED when init state future
2023-09-07 11:13:05,824 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] is in state CREATED when init state future
2023-09-07 11:13:05,826 INFO  org.apache.seatunnel.engine.client.job.ClientJobProxy - Submit job finished, job id:<PHONE_NUMBER>54293505, job name: SeaTunnel
2023-09-07 11:13:05,828 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Job Job SeaTunnel_Job<PHONE_NUMBER>54293505) waiting for scheduler finished
2023-09-07 11:13:05,831 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job<PHONE_NUMBER>54293505) turn from state CREATED to SCHEDULED.
2023-09-07 11:13:05,835 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)] turn from state CREATED to SCHEDULED.
2023-09-07 11:13:05,839 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from CREATED to SCHEDULED
2023-09-07 11:13:05,842 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state CREATED to SCHEDULED.
2023-09-07 11:13:05,848 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from CREATED to SCHEDULED
2023-09-07 11:13:05,849 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state CREATED to SCHEDULED.
2023-09-07 11:13:05,850 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to SCHEDULED
2023-09-07 11:13:05,851 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state CREATED to SCHEDULED.
2023-09-07 11:13:05,859 WARN  org.apache.seatunnel.engine.client.job.JobMetricsRunner - Failed to get job metrics summary, it maybe first-run
2023-09-07 11:13:05,859 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-07 11:13:05,862 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from SCHEDULED to DEPLOYING
2023-09-07 11:13:05,863 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-07 11:13:05,865 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from SCHEDULED to DEPLOYING
2023-09-07 11:13:05,867 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-07 11:13:05,868 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to DEPLOYING
2023-09-07 11:13:05,869 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-07 11:13:05,883 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] received deploying task executionId [752003415764107265]
2023-09-07 11:13:05,894 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] received deploying task executionId [752003415764172801]
2023-09-07 11:13:05,904 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying task TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=1}, executionId [752003415764107265]
2023-09-07 11:13:05,904 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=1} init success
2023-09-07 11:13:05,905 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] received deploying task executionId [752003415764238337]
2023-09-07 11:13:05,909 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=1} success
2023-09-07 11:13:05,910 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from DEPLOYING to RUNNING
2023-09-07 11:13:05,910 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc-default-identifier]
2023-09-07 11:13:05,912 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-07 11:13:05,931 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying task TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=3}, executionId [752003415764172801]
2023-09-07 11:13:05,932 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=3} init success
2023-09-07 11:13:05,932 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=3} success
2023-09-07 11:13:05,934 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from DEPLOYING to RUNNING
2023-09-07 11:13:05,935 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-07 11:13:05,955 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying task TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000}, executionId [752003415764238337]
2023-09-07 11:13:05,956 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000} init success
2023-09-07 11:13:05,957 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000} success
2023-09-07 11:13:05,957 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to RUNNING
2023-09-07 11:13:05,960 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-07 11:13:05,960 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)] turn from state DEPLOYING to RUNNING.
2023-09-07 11:13:05,961 INFO  org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask - starting seatunnel transform task, index 0
2023-09-07 11:13:05,961 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job<PHONE_NUMBER>54293505) turn from state SCHEDULED to RUNNING.
2023-09-07 11:13:05,962 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Job SeaTunnel_Job<PHONE_NUMBER>54293505) scheduler finished
2023-09-07 11:13:05,969 INFO  org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask - starting seatunnel source task, index 0
2023-09-07 11:13:06,332 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000}, taskID=60000, index=0}
2023-09-07 11:13:07,017 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator...
2023-09-07 11:13:07,019 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits.
2023-09-07 11:13:07,020 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Assigning JdbcSourceSplit(parameterValues=null, splitId=0) to 0 reader.
2023-09-07 11:13:07,021 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Assign splits [JdbcSourceSplit(parameterValues=null, splitId=0)] to reader 0
java.lang.OutOfMemoryError: Java heap space
Dumping heap to java_pid57818.hprof ...
Heap dump file created [72102428 bytes in 0.305 secs]
2023-09-07 11:13:08,678 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@1a7e3661
java.lang.OutOfMemoryError: Java heap space
        at java.util.Arrays.copyOf(Arrays.java:3236) ~[?:1.8.0_221]
        at org.apache.paimon.data.AbstractBinaryWriter.grow(AbstractBinaryWriter.java:262) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.AbstractBinaryWriter.ensureCapacity(AbstractBinaryWriter.java:194) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.AbstractBinaryWriter.writeSegmentsToVarLenPart(AbstractBinaryWriter.java:203) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.AbstractBinaryWriter.writeString(AbstractBinaryWriter.java:71) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.BinaryRowWriter.writeString(BinaryRowWriter.java:25) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.BinaryWriter.write(BinaryWriter.java:121) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.serializer.InternalRowSerializer.toBinaryRow(InternalRowSerializer.java:155) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.serializer.InternalRowSerializer.serializeToPages(InternalRowSerializer.java:170) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.data.serializer.InternalRowSerializer.serializeToPages(InternalRowSerializer.java:39) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.sort.BinaryInMemorySortBuffer.write(BinaryInMemorySortBuffer.java:176) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.mergetree.SortBufferWriteBuffer.put(SortBufferWriteBuffer.java:106) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.mergetree.MergeTreeWriter.write(MergeTreeWriter.java:146) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.mergetree.MergeTreeWriter.write(MergeTreeWriter.java:53) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.operation.AbstractFileStoreWrite.write(AbstractFileStoreWrite.java:93) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.table.sink.TableWriteImpl.writeAndReturn(TableWriteImpl.java:94) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.paimon.table.sink.TableWriteImpl.write(TableWriteImpl.java:83) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.write(PaimonSinkWriter.java:109) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.write(PaimonSinkWriter.java:49) ~[connector-paimon-2.3.3.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:227) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:61) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue$$Lambda$2035/1935579074.accept(Unknown Source) ~[?:?]
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:76) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:51) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:52) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) ~[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_221]
2023-09-07 11:13:08,694 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] taskDone, taskId = 70000, taskGroup = TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000}
2023-09-07 11:13:08,695 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@292ee6d0
java.lang.RuntimeException: java.lang.InterruptedException
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:41) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:46) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:28) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:139) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.collect(SeaTunnelSourceCollector.java:67) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader.pollNext(JdbcSourceReader.java:64) ~[connector-jdbc-2.3.3.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:150) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:95) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:100) ~[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_221]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_221]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_221]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_221]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_221]
Caused by: java.lang.InterruptedException
        at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) ~[?:1.8.0_221]
        at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048) ~[?:1.8.0_221]
        at java.util.concurrent.ArrayBlockingQueue.put(ArrayBlockingQueue.java:353) ~[?:1.8.0_221]
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:76) ~[seatunnel-starter.jar:2.3.3]
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:39) ~[seatunnel-starter.jar:2.3.3]
        ... 15 more
2023-09-07 11:13:08,696 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] taskDone, taskId = 60000, taskGroup = TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000}
2023-09-07 11:13:08,696 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-748082] [5.1] Task TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000} complete with state FAILED
2023-09-07 11:13:08,696 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-748082] [5.1] Received task end from execution TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000}, state FAILED
2023-09-07 11:13:08,700 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to end state FAILED.
2023-09-07 11:13:08,700 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] end with state FAILED and Exception: java.lang.OutOfMemoryError: Java heap space
        at java.util.Arrays.copyOf(Arrays.java:3236)
        at org.apache.paimon.data.AbstractBinaryWriter.grow(AbstractBinaryWriter.java:262)
        at org.apache.paimon.data.AbstractBinaryWriter.ensureCapacity(AbstractBinaryWriter.java:194)
        at org.apache.paimon.data.AbstractBinaryWriter.writeSegmentsToVarLenPart(AbstractBinaryWriter.java:203)
        at org.apache.paimon.data.AbstractBinaryWriter.writeString(AbstractBinaryWriter.java:71)
        at org.apache.paimon.data.BinaryRowWriter.writeString(BinaryRowWriter.java:25)
        at org.apache.paimon.data.BinaryWriter.write(BinaryWriter.java:121)
        at org.apache.paimon.data.serializer.InternalRowSerializer.toBinaryRow(InternalRowSerializer.java:155)
        at org.apache.paimon.data.serializer.InternalRowSerializer.serializeToPages(InternalRowSerializer.java:170)
        at org.apache.paimon.data.serializer.InternalRowSerializer.serializeToPages(InternalRowSerializer.java:39)
        at org.apache.paimon.sort.BinaryInMemorySortBuffer.write(BinaryInMemorySortBuffer.java:176)
        at org.apache.paimon.mergetree.SortBufferWriteBuffer.put(SortBufferWriteBuffer.java:106)
        at org.apache.paimon.mergetree.MergeTreeWriter.write(MergeTreeWriter.java:146)
        at org.apache.paimon.mergetree.MergeTreeWriter.write(MergeTreeWriter.java:53)
        at org.apache.paimon.operation.AbstractFileStoreWrite.write(AbstractFileStoreWrite.java:93)
        at org.apache.paimon.table.sink.TableWriteImpl.writeAndReturn(TableWriteImpl.java:94)
        at org.apache.paimon.table.sink.TableWriteImpl.write(TableWriteImpl.java:83)
        at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.write(PaimonSinkWriter.java:109)
        at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.write(PaimonSinkWriter.java:49)
        at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:227)
        at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:61)
        at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39)
        at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27)
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue$$Lambda$2035/1935579074.accept(Unknown Source)
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:76)
        at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:51)
        at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:52)
        at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73)
        at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168)
        at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78)
        at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)

2023-09-07 11:13:08,700 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=752003406054293505, pipelineId=1, taskGroupId=50000} Failed in Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline.
2023-09-07 11:13:08,700 WARN  org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job<PHONE_NUMBER>54293505), Pipeline: [(1/1)] count = 0

Zeta or Flink or Spark Version
flink 1.17
Java or Scala Version
javaversion:1.8
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

@luzongzhu Would you like to provide dump file?

@luzongzhu您想提供转储文件吗？

java_pid114491.zip

@CheneyYin this file
java_pid57818.zip

@CheneyYin I flipped through the config directory，update jvm_client_options file，JVM Heap -Xms5G -Xmx5G
Re execute
./seatunnel.sh --config ../config/v2.batch.config.template -e local
It's still abnormal, but it's not java.lang.OutOfMemoryError: Java heap space，The error message is as follows：
hs_err_pid24404.log

@CheneyYin I flipped through the config directory，update jvm_client_options file，JVM Heap -Xms5G -Xmx5G Re execute ./seatunnel.sh --config ../config/v2.batch.config.template -e local It's still abnormal, but it's not java.lang.OutOfMemoryError: Java heap space，The error message is as follows：
hs_err_pid24404.log

Thanks

@CheneyYin I flipped through the config directory，update jvm_client_options file，JVM Heap -Xms5G -Xmx5G Re execute ./seatunnel.sh --config ../config/v2.batch.config.template -e local It's still abnormal, but it's not java.lang.OutOfMemoryError: Java heap space，The error message is as follows：
hs_err_pid24404.log

Would you like to show table schema and some rows of BIODS.EKKN. I'm guessing that the error might be happening in the row/type convertor.
@TyrantLucifer PTAL

@CheneyYin @TyrantLucifer I want to write this table to paimon，BIODS.EKKN Data volume: 400,000，I tried modifying the query sql SELECT * FROM BIODS.EKKN Let him query only one piece of data，Still has no effect。

@CheneyYin flink paimon create table
CREATE TABLE pm.biods.ekkn
(
ebeln            STRING,
ebelp            STRING,
mandt            STRING,
zekkn            STRING,
loekz            STRING,
aedat            STRING,
kflag            STRING,
menge            DECIMAL(13, 3),
vproz            DECIMAL(3, 1),
netwr            DECIMAL(13, 2),
sakto            STRING,
gsber            STRING,
kostl            STRING,
projn            STRING,
vbeln            STRING,
vbelp            STRING,
veten            STRING,
kzbrb            STRING,
anln1            STRING,
anln2            STRING,
aufnr            STRING,
wempf            STRING,
ablad            STRING,
kokrs            STRING,
xbkst            STRING,
xbauf            STRING,
xbpro            STRING,
erekz            STRING,
kstrg            STRING,
paobjnr          STRING,
prctr            STRING,
ps_psp_pnr       STRING,
nplnr            STRING,
aufpl            STRING,
imkey            STRING,
aplzl            STRING,
vptnr            STRING,
fipos            STRING,
recid            STRING,
zzfzh            STRING,
zzpth            STRING,
zzicp            STRING,
zzbran1          STRING,
fistl            STRING,
geber            STRING,
fkber            STRING,
dabrz            STRING,
aufpl_ord        STRING,
aplzl_ord        STRING,
mwskz            STRING,
txjcd            STRING,
navnw            DECIMAL(13, 2),
kblnr            STRING,
kblpos           STRING,
lstar            STRING,
prznr            STRING,
grant_nbr        STRING,
budget_pd        STRING,
fm_split_batch   STRING,
fm_split_begru   STRING,
aa_final_ind     STRING,
aa_final_reason  STRING,
aa_final_qty     DECIMAL(13, 3),
egrup            STRING,
vname            STRING,
tcobjnr          STRING,
dateofservice    STRING,
notaxcorr        STRING,
diffoptrate      DECIMAL(9, 6),
hasdiffoptrate   STRING,
fmfgus_key       STRING,
aa_final_qty_f   DECIMAL(13, 2),
menge_f          DECIMAL(13, 2),
fdop_import_time STRING,
PRIMARY KEY (ebeln, ebelp) NOT ENFORCED
);
�

@CheneyYin Sorry, the previous memory overflow issue should have been caused by an inconsistency in the number of sink and source columns. After adjusting (hoping to add a verification later), I found that there will still be new exceptions. The error log is attached. Thanks

2023-09-08 15:10:54,765 WARN  org.apache.seatunnel.core.starter.seatunnel.args.ClientCommandArgs$MasterTypeValidator -

-e and --deploy-mode deprecated in 2.3.1, please use -m and --master instead of it

Sep 08, 2023 3:10:54 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/opt/apache-seatunnel-2.3.3/config/seatunnel.yaml' from System property 'seatunnel.config'
Sep 08, 2023 3:10:54 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /opt/apache-seatunnel-2.3.3/config/seatunnel.yaml
Sep 08, 2023 3:10:54 PM org.apache.seatunnel.engine.common.config.SeaTunnelConfig
INFO: seatunnel.home is /opt/apache-seatunnel-2.3.3/bin
Sep 08, 2023 3:10:54 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/opt/apache-seatunnel-2.3.3/config/hazelcast.yaml' from System property 'hazelcast.config'
Sep 08, 2023 3:10:54 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /opt/apache-seatunnel-2.3.3/config/hazelcast.yaml
2023-09-08 15:10:55,221 WARN  com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-46141] [5.1] You configured your member address as host name. Please be aware of that your dns can be spoofed. Make sure that your dns configurations are correct.
2023-09-08 15:10:55,221 INFO  com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-46141] [5.1] Resolving domain name 'localhost' to address(es): [<IP_ADDRESS>, 0:0:0:0:0:0:0:1]
2023-09-08 15:10:55,221 INFO  com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-46141] [5.1] Interfaces is disabled, trying to pick one address from TCP-IP config addresses: [localhost/<IP_ADDRESS>, localhost/0:0:0:0:0:0:0:1]
2023-09-08 15:10:55,243 INFO  org.apache.seatunnel.engine.server.SeaTunnelServer - SeaTunnel server start...
2023-09-08 15:10:55,245 INFO  com.hazelcast.system - [localhost]:5801 [seatunnel-46141] [5.1] Based on Hazelcast IMDG version: 5.1.0 (20220228 - 21f20e7)
2023-09-08 15:10:55,245 INFO  com.hazelcast.system - [localhost]:5801 [seatunnel-46141] [5.1] Cluster name: seatunnel-46141
2023-09-08 15:10:55,245 INFO  com.hazelcast.system - [localhost]:5801 [seatunnel-46141] [5.1]

/  |             | |                           | |
\ --.   ___   __ _   | |   _   _  _ __   _ __    ___ | |  --. \ / _ \ / ` |  | |  | | | || ' \ | ' \  / _ | |
/_/ /|  __/| (| |  | |  | || || | | || | | ||  /| |
_/  _| _,|  _/   _,||| |||| || _||_|
2023-09-08 15:10:55,245 INFO  com.hazelcast.system - [localhost]:5801 [seatunnel-46141] [5.1] Copyright © 2021-2022 The Apache Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are trademarks of The Apache Software Foundation.
2023-09-08 15:10:55,245 INFO  com.hazelcast.system - [localhost]:5801 [seatunnel-46141] [5.1] Integrity Checker is disabled. Fail-fast on corrupted executables will not be performed.
To enable integrity checker do one of the following:

Change member config using Java API: config.setIntegrityCheckerEnabled(true);
Change XML/YAML configuration property: Set hazelcast.integrity-checker.enabled to true
Add system property: -Dhz.integritychecker.enabled=true (for Hazelcast embedded, works only when loading config via Config.load)
Add environment variable: HZ_INTEGRITYCHECKER_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load)
2023-09-08 15:10:55,248 INFO  com.hazelcast.system - [localhost]:5801 [seatunnel-46141] [5.1] The Jet engine is disabled.
To enable the Jet engine on the members, do one of the following:
Change member config using Java API: config.getJetConfig().setEnabled(true)
Change XML/YAML configuration property: Set hazelcast.jet.enabled to true
Add system property: -Dhz.jet.enabled=true (for Hazelcast embedded, works only when loading config via Config.load)
Add environment variable: HZ_JET_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load)
2023-09-08 15:10:55,640 INFO  com.hazelcast.system.security - [localhost]:5801 [seatunnel-46141] [5.1] Enable DEBUG/FINE log level for log category com.hazelcast.system.security  or use -Dhazelcast.security.recommendations system property to see 🔒 security recommendations and the status of current config.
2023-09-08 15:10:55,699 INFO  com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-46141] [5.1] Using TCP/IP discovery
2023-09-08 15:10:55,700 WARN  com.hazelcast.cp.CPSubsystem - [localhost]:5801 [seatunnel-46141] [5.1] CP Subsystem is not enabled. CP data structures will operate in UNSAFE mode! Please note that UNSAFE mode will not provide strong consistency guarantees.
Sep 08, 2023 3:10:55 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/opt/apache-seatunnel-2.3.3/config/seatunnel.yaml' from System property 'seatunnel.config'
Sep 08, 2023 3:10:55 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /opt/apache-seatunnel-2.3.3/config/seatunnel.yaml
Sep 08, 2023 3:10:55 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/opt/apache-seatunnel-2.3.3/config/hazelcast.yaml' from System property 'hazelcast.config'
Sep 08, 2023 3:10:55 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /opt/apache-seatunnel-2.3.3/config/hazelcast.yaml
2023-09-08 15:10:55,864 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] The Node is not ready yet, Node state STARTING,looking forward to the next scheduling
2023-09-08 15:10:55,865 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Created new BusWork :<PHONE_NUMBER>
2023-09-08 15:10:55,876 WARN  org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - failed send heartbeat to resource manager, will retry later. this address: [localhost]:5801
2023-09-08 15:10:55,882 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1]

 CoordinatorService Thread Pool Status

activeCount               :                   0
corePoolSize              :                   0
maximumPoolSize           :<PHONE_NUMBER>
poolSize                  :                   0
completedTaskCount        :                   0
taskCount                 :                   0

2023-09-08 15:10:55,921 INFO  com.hazelcast.internal.diagnostics.Diagnostics - [localhost]:5801 [seatunnel-46141] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2023-09-08 15:10:55,933 INFO  com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5801 is STARTING
2023-09-08 15:10:55,983 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5823 is added to the blacklist.
2023-09-08 15:10:55,983 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5827 is added to the blacklist.
2023-09-08 15:10:55,983 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5825 is added to the blacklist.
2023-09-08 15:10:55,983 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5821 is added to the blacklist.
2023-09-08 15:10:55,983 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5826 is added to the blacklist.
2023-09-08 15:10:55,983 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5824 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5814 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5812 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5819 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5807 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5805 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5816 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5809 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5830 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5828 is added to the blacklist.
2023-09-08 15:10:55,984 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5817 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5818 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5813 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5803 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5802 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5811 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5810 is added to the blacklist.
2023-09-08 15:10:55,985 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5808 is added to the blacklist.
2023-09-08 15:10:55,986 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5829 is added to the blacklist.
2023-09-08 15:10:55,986 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5820 is added to the blacklist.
2023-09-08 15:10:55,986 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5822 is added to the blacklist.
2023-09-08 15:10:55,986 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5806 is added to the blacklist.
2023-09-08 15:10:55,986 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5804 is added to the blacklist.
2023-09-08 15:10:55,986 INFO  com.hazelcast.internal.cluster.impl.TcpIpJoiner - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5815 is added to the blacklist.
2023-09-08 15:10:56,984 INFO  com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-46141] [5.1]
Members {size:1, ver:1} [
Member [localhost]:5801 - 821cc7bd-d520-4383-9695-35bae64c667a this
]
2023-09-08 15:10:56,998 INFO  com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-46141] [5.1] [localhost]:5801 is STARTED
Sep 08, 2023 3:10:56 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Loading configuration '/opt/apache-seatunnel-2.3.3/config/hazelcast-client.yaml' from System property 'hazelcast.client.config'
Sep 08, 2023 3:10:56 PM com.hazelcast.internal.config.AbstractConfigLocator
INFO: Using configuration file at /opt/apache-seatunnel-2.3.3/config/hazelcast-client.yaml
2023-09-08 15:10:57,042 INFO  com.hazelcast.client.impl.spi.ClientInvocationService - hz.client_1 [seatunnel-46141] [5.1] Running with 2 response threads, dynamic=true
2023-09-08 15:10:57,101 INFO  com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-46141] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING
2023-09-08 15:10:57,102 INFO  com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-46141] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED
2023-09-08 15:10:57,112 INFO  com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-46141] [5.1] Trying to connect to cluster: seatunnel-46141
2023-09-08 15:10:57,113 INFO  com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-46141] [5.1] Trying to connect to [localhost]:5801
2023-09-08 15:10:57,128 INFO  com.hazelcast.client.impl.protocol.task.AuthenticationMessageTask - [localhost]:5801 [seatunnel-46141] [5.1] Received auth from Connection[id=1, /<IP_ADDRESS>:5801->/<IP_ADDRESS>:35347, qualifier=null, endpoint=[<IP_ADDRESS>]:35347, remoteUuid=25bf4ce2-ead7-4b58-aca4-a82e8493f194, alive=true, connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid: 25bf4ce2-ead7-4b58-aca4-a82e8493f194, client name: hz.client_1, client version: 5.1
2023-09-08 15:10:57,130 INFO  com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-46141] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_CONNECTED
2023-09-08 15:10:57,130 INFO  com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-46141] [5.1] Authenticated with server [localhost]:5801:821cc7bd-d520-4383-9695-35bae64c667a, server version: 5.1, local address: /<IP_ADDRESS>:35347
2023-09-08 15:10:57,131 INFO  com.hazelcast.internal.diagnostics.Diagnostics - hz.client_1 [seatunnel-46141] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments.
2023-09-08 15:10:57,139 INFO  com.hazelcast.client.impl.spi.ClientClusterService - hz.client_1 [seatunnel-46141] [5.1]
Members [1] {
Member [localhost]:5801 - 821cc7bd-d520-4383-9695-35bae64c667a
}
2023-09-08 15:10:57,156 INFO  com.hazelcast.client.impl.statistics.ClientStatisticsService - Client statistics is enabled with period 5 seconds.
2023-09-08 15:10:57,291 INFO  org.apache.seatunnel.engine.client.job.JobExecutionEnvironment - add common jar in plugins :[]
2023-09-08 15:10:57,311 INFO  org.apache.seatunnel.core.starter.utils.ConfigBuilder - Loading config file from path: ../config/v2.batch.config.template
2023-09-08 15:10:57,358 INFO  org.apache.seatunnel.core.starter.utils.ConfigShadeUtils - Load config shade spi: [base64]
2023-09-08 15:10:57,399 INFO  org.apache.seatunnel.core.starter.utils.ConfigBuilder - Parsed config file: {
"env" : {
"execution.parallelism" : 2,
"job.mode" : "BATCH"
},
"source" : [
{
"password" : "biods2020",
"driver" : "oracle.jdbc.OracleDriver",
"query" : "SELECT  MANDT, EBELN, EBELP, ZEKKN, LOEKZ, AEDAT, KFLAG, MENGE, VPROZ, NETWR, SAKTO, GSBER, KOSTL, PROJN, VBELN, VBELP, VETEN, KZBRB, ANLN1, ANLN2, AUFNR, WEMPF, ABLAD, KOKRS, XBKST, XBAUF, XBPRO, EREKZ, KSTRG, PAOBJNR, PRCTR, PS_PSP_PNR, NPLNR, AUFPL, IMKEY, APLZL, VPTNR, FIPOS, RECID, ZZFZH, ZZPTH, ZZICP, ZZBRAN1, FISTL, GEBER, FKBER, DABRZ, AUFPL_ORD, APLZL_ORD, MWSKZ, TXJCD, NAVNW, KBLNR, KBLPOS, LSTAR, PRZNR, GRANT_NBR, BUDGET_PD, FM_SPLIT_BATCH, FM_SPLIT_BEGRU, AA_FINAL_IND, AA_FINAL_REASON, AA_FINAL_QTY, EGRUP, VNAME, TCOBJNR, DATEOFSERVICE, NOTAXCORR, DIFFOPTRATE, HASDIFFOPTRATE, FMFGUS_KEY, AA_FINAL_QTY_F, MENGE_F,'2023-09-09 13:53:00' AS fdop_import_time FROM BIODS.EKKN",
"plugin_name" : "Jdbc",
"user" : "biods",
"url" : "jdbc:oracle:thin:@*******:1521/WFLDBDEV"
}
],
"sink" : [
{
"database" : "biods",
"warehouse" : "hdfs://********:9820/paimon",
"plugin_name" : "Paimon",
"table" : "ekkn"
}
]
}
2023-09-08 15:10:57,422 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-08 15:10:57,423 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-08 15:10:57,427 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /opt/apache-seatunnel-2.3.3/connectors/seatunnel
2023-09-08 15:10:57,435 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Jdbc at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar
2023-09-08 15:10:57,436 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Paimon at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar
2023-09-08 15:10:57,443 INFO  org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sources.
2023-09-08 15:10:57,444 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-08 15:10:57,476 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-08 15:10:57,479 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSource Plugin from /opt/apache-seatunnel-2.3.3/connectors/seatunnel
2023-09-08 15:10:57,483 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Jdbc at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar
2023-09-08 15:10:57,486 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} from classpath
2023-09-08 15:10:57,882 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1] This node become a new active master node, begin init coordinator service
2023-09-08 15:10:57,920 INFO  com.hazelcast.internal.partition.impl.PartitionStateManager - [localhost]:5801 [seatunnel-46141] [5.1] Initializing cluster partition table arrangement...
2023-09-08 15:10:58,197 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource - The partition_column parameter is not configured, and the source parallelism is set to 1
2023-09-08 15:10:58,231 INFO  org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all transforms.
2023-09-08 15:10:58,232 INFO  org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sinks.
2023-09-08 15:10:58,232 INFO  org.apache.seatunnel.api.configuration.ReadonlyConfig - Config uses fallback configuration key 'plugin_name' instead of key 'factory'
2023-09-08 15:10:58,236 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /opt/apache-seatunnel-2.3.3/connectors/seatunnel
2023-09-08 15:10:58,237 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Discovery plugin jar: Paimon at: file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar
2023-09-08 15:10:58,241 INFO  org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load plugin: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Paimon'} from classpath
2023-09-08 15:10:58,403 WARN  org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2023-09-08 15:10:59,375 INFO  org.apache.seatunnel.engine.client.job.ClientJobProxy - Start submit job, job id:<PHONE_NUMBER>87585025, with plugin jar [file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar, file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar]
2023-09-08 15:10:59,388 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - Init ResourceManager
2023-09-08 15:10:59,388 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - initWorker...
2023-09-08 15:10:59,388 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - initWorker live nodes: [[localhost]:5801]
2023-09-08 15:10:59,390 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - registerWorker: {[localhost]:5801=WorkerProfile(address=[localhost]:5801, profile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=2058354688}}, unassignedResource=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=2058354688}}, assignedSlots=[], unassignedSlots=[])}
2023-09-08 15:10:59,411 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Init JobMaster for Job SeaTunnel_Job<PHONE_NUMBER>87585025)
2023-09-08 15:10:59,412 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Job SeaTunnel_Job<PHONE_NUMBER>87585025) needed jar urls [file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-paimon-2.3.3.jar, file:/opt/apache-seatunnel-2.3.3/connectors/seatunnel/connector-jdbc-2.3.3.jar]
2023-09-08 15:10:59,589 INFO  org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage - Path /tmp/seatunnel/checkpoint_snapshot/752425662387585025 is not a directory
2023-09-08 15:10:59,589 INFO  org.apache.seatunnel.engine.checkpoint.storage.hdfs.HdfsStorage - No checkpoint found for job, job id is:<PHONE_NUMBER>87585025
2023-09-08 15:10:59,593 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] is in state CREATED when init state future
2023-09-08 15:10:59,594 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] is in state CREATED when init state future
2023-09-08 15:10:59,595 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] is in state CREATED when init state future
2023-09-08 15:10:59,597 INFO  org.apache.seatunnel.engine.client.job.ClientJobProxy - Submit job finished, job id:<PHONE_NUMBER>87585025, job name: SeaTunnel
2023-09-08 15:10:59,599 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Job Job SeaTunnel_Job<PHONE_NUMBER>87585025) waiting for scheduler finished
2023-09-08 15:10:59,602 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025) turn from state CREATED to SCHEDULED.
2023-09-08 15:10:59,608 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:10:59,613 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from CREATED to SCHEDULED
2023-09-08 15:10:59,615 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:10:59,623 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from CREATED to SCHEDULED
2023-09-08 15:10:59,625 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:10:59,625 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to SCHEDULED
2023-09-08 15:10:59,627 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:10:59,635 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:10:59,638 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from SCHEDULED to DEPLOYING
2023-09-08 15:10:59,639 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:10:59,639 WARN  org.apache.seatunnel.engine.client.job.JobMetricsRunner - Failed to get job metrics summary, it maybe first-run
2023-09-08 15:10:59,640 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from SCHEDULED to DEPLOYING
2023-09-08 15:10:59,642 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:10:59,643 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to DEPLOYING
2023-09-08 15:10:59,644 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:10:59,654 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] received deploying task executionId [752425672181284865]
2023-09-08 15:10:59,668 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] received deploying task executionId [752425672181350401]
2023-09-08 15:10:59,672 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}, executionId [752425672181284865]
2023-09-08 15:10:59,672 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1} init success
2023-09-08 15:10:59,676 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] received deploying task executionId [752425672181415937]
2023-09-08 15:10:59,681 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1} success
2023-09-08 15:10:59,681 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from DEPLOYING to RUNNING
2023-09-08 15:10:59,683 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:10:59,685 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc-default-identifier]
2023-09-08 15:10:59,707 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}, executionId [752425672181350401]
2023-09-08 15:10:59,707 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3} init success
2023-09-08 15:10:59,707 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3} success
2023-09-08 15:10:59,708 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from DEPLOYING to RUNNING
2023-09-08 15:10:59,709 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:10:59,731 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}, executionId [752425672181415937]
2023-09-08 15:10:59,732 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} init success
2023-09-08 15:10:59,733 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} success
2023-09-08 15:10:59,733 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to RUNNING
2023-09-08 15:10:59,737 INFO  org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask - starting seatunnel transform task, index 0
2023-09-08 15:10:59,737 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:10:59,740 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:10:59,742 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025) turn from state SCHEDULED to RUNNING.
2023-09-08 15:10:59,743 INFO  org.apache.seatunnel.engine.server.master.JobMaster - Job SeaTunnel_Job<PHONE_NUMBER>87585025) scheduler finished
2023-09-08 15:10:59,743 INFO  org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask - starting seatunnel source task, index 0
2023-09-08 15:11:00,085 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}, taskID=60000, index=0}
2023-09-08 15:11:00,792 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received enough reader, starting enumerator...
2023-09-08 15:11:00,794 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Starting to calculate splits.
2023-09-08 15:11:00,795 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Assigning JdbcSourceSplit(parameterValues=null, splitId=0) to 0 reader.
2023-09-08 15:11:00,795 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceSplitEnumerator - Assign splits [JdbcSourceSplit(parameterValues=null, splitId=0)] to reader 0
2023-09-08 15:11:10,736 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 1
2023-09-08 15:11:20,734 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 2
2023-09-08 15:11:30,735 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 3
2023-09-08 15:11:40,735 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 4
2023-09-08 15:11:50,735 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 5
2023-09-08 15:11:55,880 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1]

 CoordinatorService Thread Pool Status

activeCount               :                   1
corePoolSize              :                   0
maximumPoolSize           :<PHONE_NUMBER>
poolSize                  :                   6
completedTaskCount        :                  38
taskCount                 :                  39

2023-09-08 15:11:55,886 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1]

            Job info detail

createdJobCount           :                   0
scheduledJobCount         :                   0
runningJobCount           :                   1
failingJobCount           :                   0
failedJobCount            :                   0
cancellingJobCount        :                   0
canceledJobCount          :                   0
finishedJobCount          :                   0
restartingJobCount        :                   0
suspendedJobCount         :                   0
reconcilingJobCount       :                   0

2023-09-08 15:11:57,314 INFO  org.apache.paimon.shade.org.apache.orc.impl.MemoryManagerImpl - orc.rows.between.memory.checks=5000
2023-09-08 15:11:57,323 INFO  org.apache.paimon.shade.org.apache.orc.impl.OrcCodecPool - Got brand-new codec LZ4
2023-09-08 15:11:57,371 INFO  org.apache.paimon.shade.org.apache.orc.impl.WriterImpl - ORC writer created for path: 1ed2033d-38c9-481f-989d-5db0d1197a8f with stripeSize: 67108864 blockSize: 268435456 compression: LZ4 bufferSize: 65536
2023-09-08 15:11:59,652 INFO  org.apache.seatunnel.engine.client.job.JobMetricsRunner -

       Job Progress Information

Job Id                    :<PHONE_NUMBER>87585025
Read Count So Far         :              311610
Write Count So Far        :              309561
Average Read Count        :              5193/s
Average Write Count       :              5159/s
Last Statistic Time       : 2023-09-08 15:10:59
Current Statistic Time    : 2023-09-08 15:11:59

2023-09-08 15:12:00,735 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - wait checkpoint completed: 6
2023-09-08 15:12:05,799 INFO  org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader - Closed the bounded jdbc source
2023-09-08 15:12:05,885 INFO  org.apache.paimon.shade.org.apache.orc.impl.WriterImpl - ORC writer created for path: 61c7439e-c6eb-4868-8ff8-433210e11b81 with stripeSize: 67108864 blockSize: 268435456 compression: LZ4 bufferSize: 65536
2023-09-08 15:12:06,258 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Exception in org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@31601e43
java.lang.RuntimeException: org.apache.seatunnel.connectors.seatunnel.paimon.exception.PaimonConnectorException: ErrorCode:[PAIMON-03], ErrorDescription:[Paimon pre commit failed] - Flink table store failed to prepare commit
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:232) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:61) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:71) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:51) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:52) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78) ~[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_221]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_221]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_221]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_221]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_221]
Caused by: org.apache.seatunnel.connectors.seatunnel.paimon.exception.PaimonConnectorException: ErrorCode:[PAIMON-03], ErrorDescription:[Paimon pre commit failed] - Flink table store failed to prepare commit
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.prepareCommit(PaimonSinkWriter.java:125) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:166) ~[seatunnel-starter.jar:2.3.3]
... 15 more
Caused by: java.lang.IllegalStateException: BatchTableWrite only support one-time committing.
at org.apache.paimon.utils.Preconditions.checkState(Preconditions.java:182) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.table.sink.TableWriteImpl.prepareCommit(TableWriteImpl.java:131) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.prepareCommit(PaimonSinkWriter.java:121) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:166) ~[seatunnel-starter.jar:2.3.3]
... 15 more
2023-09-08 15:12:06,267 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 70000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}
2023-09-08 15:12:06,268 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 60000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@76893359
2023-09-08 15:12:06,268 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 60000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}
2023-09-08 15:12:06,269 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} complete with state FAILED
2023-09-08 15:12:06,270 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1] Received task end from execution TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}, state FAILED
2023-09-08 15:12:06,272 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to end state FAILED.
2023-09-08 15:12:06,272 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] end with state FAILED and Exception: java.lang.RuntimeException: org.apache.seatunnel.connectors.seatunnel.paimon.exception.PaimonConnectorException: ErrorCode:[PAIMON-03], ErrorDescription:[Paimon pre commit failed] - Flink table store failed to prepare commit
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:232)
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:61)
at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:39)
at org.apache.seatunnel.engine.server.task.SeaTunnelTransformCollector.collect(SeaTunnelTransformCollector.java:27)
at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:71)
at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:51)
at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:52)
at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:73)
at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:168)
at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:78)
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:748)
Caused by: org.apache.seatunnel.connectors.seatunnel.paimon.exception.PaimonConnectorException: ErrorCode:[PAIMON-03], ErrorDescription:[Paimon pre commit failed] - Flink table store failed to prepare commit
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.prepareCommit(PaimonSinkWriter.java:125)
at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:166)
... 15 more
Caused by: java.lang.IllegalStateException: BatchTableWrite only support one-time committing.
at org.apache.paimon.utils.Preconditions.checkState(Preconditions.java:182)
at org.apache.paimon.table.sink.TableWriteImpl.prepareCommit(TableWriteImpl.java:131)
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.PaimonSinkWriter.prepareCommit(PaimonSinkWriter.java:121)
... 16 more
2023-09-08 15:12:06,273 ERROR org.apache.seatunnel.engine.server.dag.physical.SubPlan - Task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} Failed in Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline.
2023-09-08 15:12:06,273 WARN  org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] count = 0
2023-09-08 15:12:06,273 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:06,275 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause Pipeline turn to end state.
2023-09-08 15:12:06,279 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - skip this checkpoint cause by completedCheckpoint is null
2023-09-08 15:12:06,279 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - skip this checkpoint cause by completedCheckpoint is null
2023-09-08 15:12:06,279 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - skip this checkpoint cause by completedCheckpoint is null
2023-09-08 15:12:06,279 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - skip this checkpoint cause by completedCheckpoint is null
2023-09-08 15:12:06,279 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - skip this checkpoint cause by completedCheckpoint is null
2023-09-08 15:12:06,312 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - pending checkpoint(6/1@752425662387585025) notify finished!
2023-09-08 15:12:06,312 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start notify checkpoint completed, checkpoint:org.apache.seatunnel.engine.server.checkpoint.CompletedCheckpoint@3782d8c1
2023-09-08 15:12:06,753 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_752425662387585025_1 state from null to CANCELED
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from CREATED to CANCELED
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from CREATED to CANCELED
2023-09-08 15:12:06,756 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state in Imap is RUNNING, not equals expected state CREATED
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from SCHEDULED to CANCELED
2023-09-08 15:12:06,756 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state in Imap is RUNNING, not equals expected state CREATED
2023-09-08 15:12:06,756 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state in Imap is RUNNING, not equals expected state SCHEDULED
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from SCHEDULED to CANCELED
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from DEPLOYING to CANCELED
2023-09-08 15:12:06,756 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state in Imap is RUNNING, not equals expected state SCHEDULED
2023-09-08 15:12:06,756 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state in Imap is RUNNING, not equals expected state DEPLOYING
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from RUNNING to CANCELING
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from DEPLOYING to CANCELED
2023-09-08 15:12:06,756 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state in Imap is RUNNING, not equals expected state DEPLOYING
2023-09-08 15:12:06,756 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from RUNNING to CANCELING
2023-09-08 15:12:06,758 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:06,759 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:06,761 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] operator to member [localhost]:5801
2023-09-08 15:12:06,761 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] operator to member [localhost]:5801
2023-09-08 15:12:06,761 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task (TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}) need cancel.
2023-09-08 15:12:06,761 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task (TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}) need cancel.
2023-09-08 15:12:06,761 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SinkAggregatedCommitterTask@653217af
2023-09-08 15:12:06,762 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 20000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@7223a62
2023-09-08 15:12:06,762 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}
2023-09-08 15:12:06,762 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}
2023-09-08 15:12:06,762 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1} complete with state CANCELED
2023-09-08 15:12:06,762 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3} complete with state CANCELED
2023-09-08 15:12:06,762 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1] Received task end from execution TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}, state CANCELED
2023-09-08 15:12:06,762 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1] Received task end from execution TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}, state CANCELED
2023-09-08 15:12:06,763 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn to end state CANCELED.
2023-09-08 15:12:06,763 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] end with state CANCELED
2023-09-08 15:12:06,764 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to end state CANCELED.
2023-09-08 15:12:06,764 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] end with state CANCELED
2023-09-08 15:12:06,764 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] end with state FAILED
2023-09-08 15:12:06,765 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn to end state FAILED.
2023-09-08 15:12:06,765 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Restore time 1, pipeline Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)]
2023-09-08 15:12:06,766 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Reset pipeline Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] state to CREATED
2023-09-08 15:12:06,766 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Reset pipeline Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] state to CREATED complete
2023-09-08 15:12:06,768 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn to state CREATED.
2023-09-08 15:12:06,769 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn to state CREATED.
2023-09-08 15:12:06,770 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to state CREATED.
2023-09-08 15:12:06,770 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] is in state CREATED when init state future
2023-09-08 15:12:06,770 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] is in state CREATED when init state future
2023-09-08 15:12:06,771 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] is in state CREATED when init state future
2023-09-08 15:12:06,771 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointManager - reported pipeline running stack: [java.lang.Thread.getStackTrace(Thread.java:1559), 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:656), java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632), java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624), java.lang.Thread.run(Thread.java:748)]
2023-09-08 15:12:06,771 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - received restore CheckpointCoordinator with alreadyStarted= false
2023-09-08 15:12:06,771 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_752425662387585025_1 state from CANCELED to RUNNING
2023-09-08 15:12:06,772 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause CheckpointCoordinator reset.
2023-09-08 15:12:06,772 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:12:06,774 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - received slot active check success, profile: SlotProfile{worker=[localhost]:5801, slotID=1, ownerJobID=752425662387585025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='f2930140-cfff-4a31-872e-ed47cdd169c3'}
2023-09-08 15:12:06,774 INFO  org.apache.seatunnel.engine.server.scheduler.PipelineBaseScheduler - use active old profile: SlotProfile{worker=[localhost]:5801, slotID=1, ownerJobID=752425662387585025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='f2930140-cfff-4a31-872e-ed47cdd169c3'} for task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)]
2023-09-08 15:12:06,774 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from CREATED to SCHEDULED
2023-09-08 15:12:06,775 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:12:06,775 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - received slot active check success, profile: SlotProfile{worker=[localhost]:5801, slotID=2, ownerJobID=752425662387585025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='f2930140-cfff-4a31-872e-ed47cdd169c3'}
2023-09-08 15:12:06,775 INFO  org.apache.seatunnel.engine.server.scheduler.PipelineBaseScheduler - use active old profile: SlotProfile{worker=[localhost]:5801, slotID=2, ownerJobID=752425662387585025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='f2930140-cfff-4a31-872e-ed47cdd169c3'} for task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)]
2023-09-08 15:12:06,775 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from CREATED to SCHEDULED
2023-09-08 15:12:06,775 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:12:06,776 INFO  org.apache.seatunnel.engine.server.resourcemanager.AbstractResourceManager - received slot active check success, profile: SlotProfile{worker=[localhost]:5801, slotID=3, ownerJobID=752425662387585025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='f2930140-cfff-4a31-872e-ed47cdd169c3'}
2023-09-08 15:12:06,776 INFO  org.apache.seatunnel.engine.server.scheduler.PipelineBaseScheduler - use active old profile: SlotProfile{worker=[localhost]:5801, slotID=3, ownerJobID=752425662387585025, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='f2930140-cfff-4a31-872e-ed47cdd169c3'} for task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)]
2023-09-08 15:12:06,776 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to SCHEDULED
2023-09-08 15:12:06,776 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state CREATED to SCHEDULED.
2023-09-08 15:12:06,778 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:12:06,778 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from SCHEDULED to DEPLOYING
2023-09-08 15:12:06,779 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:12:06,779 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from SCHEDULED to DEPLOYING
2023-09-08 15:12:06,780 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:12:06,780 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to DEPLOYING
2023-09-08 15:12:06,781 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state SCHEDULED to DEPLOYING.
2023-09-08 15:12:06,781 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] received deploying task executionId [752425672181481473]
2023-09-08 15:12:06,793 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] received deploying task executionId [752425672181612545]
2023-09-08 15:12:06,796 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] received deploying task executionId [752425672181547009]
2023-09-08 15:12:06,800 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}, executionId [752425672181481473]
2023-09-08 15:12:06,800 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1} init success
2023-09-08 15:12:06,801 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1} success
2023-09-08 15:12:06,802 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from DEPLOYING to RUNNING
2023-09-08 15:12:06,803 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:12:06,803 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc-default-identifier]
2023-09-08 15:12:06,828 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}, executionId [752425672181547009]
2023-09-08 15:12:06,828 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3} init success
2023-09-08 15:12:06,829 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3} success
2023-09-08 15:12:06,829 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from DEPLOYING to RUNNING
2023-09-08 15:12:06,829 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:12:06,837 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}, executionId [752425672181612545]
2023-09-08 15:12:06,837 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} init success
2023-09-08 15:12:06,841 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] deploying TaskGroup TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} success
2023-09-08 15:12:06,841 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to RUNNING
2023-09-08 15:12:06,841 INFO  org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask - starting seatunnel transform task, index 0
2023-09-08 15:12:06,845 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:12:06,852 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state DEPLOYING to RUNNING.
2023-09-08 15:12:06,853 INFO  org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask - starting seatunnel source task, index 0
2023-09-08 15:12:07,180 INFO  org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}, taskID=60000, index=0}
2023-09-08 15:12:07,938 WARN  org.apache.paimon.operation.FileStoreCommitImpl - File deletion conflicts detected! Give up committing.
java.lang.IllegalStateException: Trying to add file {org.apache.paimon.data.BinaryRow@9c67b85d, 0, 0, data-806293c3-b835-4026-8b25-27904ea7656a-0.orc} which is already added. Manifest might be corrupted.
at org.apache.paimon.utils.Preconditions.checkState(Preconditions.java:204) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.manifest.ManifestEntry.mergeEntries(ManifestEntry.java:127) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.manifest.ManifestEntry.mergeEntries(ManifestEntry.java:117) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.operation.FileStoreCommitImpl.noConflictsOrFail(FileStoreCommitImpl.java:729) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.operation.FileStoreCommitImpl.commit(FileStoreCommitImpl.java:215) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.table.sink.TableCommitImpl.commit(TableCommitImpl.java:101) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.paimon.table.sink.TableCommitImpl.commit(TableCommitImpl.java:160) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.commit.PaimonAggregatedCommitter.commit(PaimonAggregatedCommitter.java:65) ~[connector-paimon-2.3.3.jar:2.3.3]
at org.apache.seatunnel.engine.server.task.SinkAggregatedCommitterTask.restoreState(SinkAggregatedCommitterTask.java:266) ~[seatunnel-starter.jar:2.3.3]
at org.apache.seatunnel.engine.server.checkpoint.operation.NotifyTaskRestoreOperation.lambda$null$0(NotifyTaskRestoreOperation.java:106) ~[seatunnel-starter.jar:2.3.3]
at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1626) [?:1.8.0_221]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_221]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_221]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_221]
2023-09-08 15:12:07,942 ERROR org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - report error from task
org.apache.seatunnel.common.utils.SeaTunnelException: org.apache.seatunnel.connectors.seatunnel.paimon.exception.PaimonConnectorException: ErrorCode:[PAIMON-01], ErrorDescription:[Paimon write commit failed] - Flink table store commit operation failed
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.commit.PaimonAggregatedCommitter.commit(PaimonAggregatedCommitter.java:67)
at org.apache.seatunnel.engine.server.task.SinkAggregatedCommitterTask.restoreState(SinkAggregatedCommitterTask.java:266)
at org.apache.seatunnel.engine.server.checkpoint.operation.NotifyTaskRestoreOperation.lambda$null$0(NotifyTaskRestoreOperation.java:106)
at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1626)
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:748)
Caused by: java.lang.RuntimeException: File deletion conflicts detected! Give up committing.
Conflicts during commits are normal and this failure is intended to resolve the conflicts.
Conflicts are mainly caused by the following scenarios:

Multiple jobs are writing into the same partition at the same time, you can use https://paimon.apache.org/docs/master/maintenance/write-performance/#dedicated-compaction-job to support multiple writing.
You're recovering from an old savepoint, or you're creating multiple jobs from a savepoint.
The job will fail continuously in this scenario to protect metadata from corruption.
You can either recover from the latest savepoint, or you can revert the table to the snapshot corresponding to the old savepoint.

Base entries are:
{ADD, org.apache.paimon.data.BinaryRow@9c67b85d, 0, 1, {data-806293c3-b835-4026-8b25-27904ea7656a-0.orc, 2146965, 104317, org.apache.paimon.data.BinaryRow@f95cc52b, org.apache.paimon.data.BinaryRow@5f02471d, org.apache.paimon.stats.BinaryTableStats@96873b0e, org.apache.paimon.stats.BinaryTableStats@d90cb1e4, 6, 309560, 0, 0, [], 2023-09-08T07:11:59.760}}
{ADD, org.apache.paimon.data.BinaryRow@9c67b85d, 0, 1, {data-806293c3-b835-4026-8b25-27904ea7656a-1.orc, 292452, 11975, org.apache.paimon.data.BinaryRow@fb19def, org.apache.paimon.data.BinaryRow@ac55f11b, org.apache.paimon.stats.BinaryTableStats@c82a8894, org.apache.paimon.stats.BinaryTableStats@d44ec9ac, 309562, 346083, 0, 0, [], 2023-09-08T07:12:06.222}}
Changes are:
{ADD, org.apache.paimon.data.BinaryRow@9c67b85d, 0, 1, {data-806293c3-b835-4026-8b25-27904ea7656a-0.orc, 2146965, 104317, org.apache.paimon.data.BinaryRow@f95cc52b, org.apache.paimon.data.BinaryRow@5f02471d, org.apache.paimon.stats.BinaryTableStats@96873b0e, org.apache.paimon.stats.BinaryTableStats@d90cb1e4, 6, 309560, 0, 0, [], 2023-09-08T07:11:59.760}}
{ADD, org.apache.paimon.data.BinaryRow@9c67b85d, 0, 1, {data-806293c3-b835-4026-8b25-27904ea7656a-1.orc, 292452, 11975, org.apache.paimon.data.BinaryRow@fb19def, org.apache.paimon.data.BinaryRow@ac55f11b, org.apache.paimon.stats.BinaryTableStats@c82a8894, org.apache.paimon.stats.BinaryTableStats@d44ec9ac, 309562, 346083, 0, 0, [], 2023-09-08T07:12:06.222}}
at org.apache.paimon.operation.FileStoreCommitImpl.createConflictException(FileStoreCommitImpl.java:797)
at org.apache.paimon.operation.FileStoreCommitImpl.noConflictsOrFail(FileStoreCommitImpl.java:733)
at org.apache.paimon.operation.FileStoreCommitImpl.commit(FileStoreCommitImpl.java:215)
at org.apache.paimon.table.sink.TableCommitImpl.commit(TableCommitImpl.java:101)
at org.apache.paimon.table.sink.TableCommitImpl.commit(TableCommitImpl.java:160)
at org.apache.seatunnel.connectors.seatunnel.paimon.sink.commit.PaimonAggregatedCommitter.commit(PaimonAggregatedCommitter.java:65)
... 6 more
    at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:344) [seatunnel-starter.jar:2.3.3]
    at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:188) [seatunnel-starter.jar:2.3.3]
    at org.apache.seatunnel.engine.server.checkpoint.operation.CheckpointErrorReportOperation.run(CheckpointErrorReportOperation.java:48) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) [seatunnel-starter.jar:2.3.3]
    at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) [seatunnel-starter.jar:2.3.3]

2023-09-08 15:12:07,943 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - start clean pending checkpoint cause CheckpointCoordinator inside have error.
2023-09-08 15:12:07,943 INFO  org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator - Turn checkpoint_state_752425662387585025_1 state from RUNNING to FAILED
2023-09-08 15:12:07,944 WARN  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] checkpoint have error, cancel the pipeline
2023-09-08 15:12:07,944 WARN  org.apache.seatunnel.engine.server.dag.physical.SubPlan - start cancel job Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] count = 0
2023-09-08 15:12:07,945 INFO  org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from CREATED to CANCELED
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state in Imap is RUNNING, not equals expected state CREATED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from CREATED to CANCELED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from SCHEDULED to CANCELED
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state in Imap is RUNNING, not equals expected state SCHEDULED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from CREATED to CANCELED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from DEPLOYING to CANCELED
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state in Imap is RUNNING, not equals expected state DEPLOYING
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), 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-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state in Imap is RUNNING, not equals expected state CREATED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] state from RUNNING to CANCELING
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from SCHEDULED to CANCELED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from SCHEDULED to CANCELED
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state in Imap is RUNNING, not equals expected state SCHEDULED
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), 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-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from DEPLOYING to CANCELED
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state in Imap is RUNNING, not equals expected state DEPLOYING
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from DEPLOYING to CANCELED
2023-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] state from RUNNING to CANCELING
2023-09-08 15:12:07,946 WARN  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - The task Job SeaTunnel_Job<PHONE_NUMBER>87585025), 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-09-08 15:12:07,946 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Try to update the task Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] state from RUNNING to CANCELING
2023-09-08 15:12:07,947 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:07,947 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:07,947 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn from state RUNNING to CANCELING.
2023-09-08 15:12:07,948 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] operator to member [localhost]:5801
2023-09-08 15:12:07,948 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task (TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}) need cancel.
2023-09-08 15:12:07,949 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 40000 - org.apache.seatunnel.engine.server.task.SinkAggregatedCommitterTask@6fb582bf
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 40000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] operator to member [localhost]:5801
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3} complete with state CANCELED
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task (TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}) need cancel.
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1] Received task end from execution TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=3}, state CANCELED
2023-09-08 15:12:07,949 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 70000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@5bdbb418
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 70000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}
2023-09-08 15:12:07,949 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 60000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@13664154
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 60000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000} complete with state CANCELED
2023-09-08 15:12:07,949 INFO  org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-46141] [5.1] Received task end from execution TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=50000}, state CANCELED
2023-09-08 15:12:07,950 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] turn to end state CANCELED.
2023-09-08 15:12:07,950 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Sink[0]-Paimon-default-identifier]-AggregatedCommitterTask (1/1)] end with state CANCELED
2023-09-08 15:12:07,950 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] turn to end state CANCELED.
2023-09-08 15:12:07,950 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (1/1)] end with state CANCELED
2023-09-08 15:12:07,951 INFO  org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Send cancel Job SeaTunnel_Job<PHONE_NUMBER>87585025), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SplitEnumerator (1/1)] operator to member [localhost]:5801
2023-09-08 15:12:07,951 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Task (TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}) need cancel.
2023-09-08 15:12:07,953 WARN  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] Interrupted task 20000 - org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@120835d9
2023-09-08 15:12:07,953 INFO  org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-46141] [5.1] taskDone, taskId = 20000, taskGroup = TaskGroupLocation{jobId=752425662387585025, pipelineId=1, taskGroupId=1}