jiexiadwo opened a new issue, #6560: URL: https://github.com/apache/seatunnel/issues/6560
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened oracle-cdc同步至starrocks 出现 Generate Splits for table error和java.lang.NullPointerException ### SeaTunnel Version 2.3.4 ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "STREAMING" # STREAMING BATCH job.name="##mysql_2_sr##" checkpoint.interval = 10000 } source { Oracle-CDC { result_table_name = "mng_componentsmapping" username = "flinkuser" password = "mapapp" database-names = ["XAMQ"] schema-names = ["GRID_SYSDB"] table-names = ["XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING"] base-url = "jdbc:oracle:thin:flinkuser/[email protected]:1521/xamq" source.reader.close.timeout = 120000 debezium { # log.mining.strategy = "online_catalog" # log.mining.continuous.mine = true database.oracle.jdbc.timezoneAsRegion = "false" } table-names-config = [ { table = "XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING" primaryKeys = ["CODE_ID"] } ] } } transform { sql { source_table_name = "mng_componentsmapping" result_table_name = "mng_mapping" query = "select * from mng_componentsmapping" } } sink { # Console { # source_table_name = "mng_mapping" # } StarRocks { base-url = "jdbc:mysql://172.18.xx.xx:9030" nodeUrls = ["172.18.xx.xx:8030"] username = root password = root database = "grid_city" table = "mng_mapping" batch_max_rows = 10 starrocks.config = { format = "JSON" strip_outer_array = true } #enable_upsert_delete = true savemode="KEEP_SCHEMA_AND_DATA" source_table_name = ["mng_mapping"] } } ``` ### Running Command ```shell ./bin/seatunnel.sh --config ./config/oraclecdc_2_sr.config -e local ``` ### Error Exception ```log 2024-03-22 15:57:01,579 INFO [o.a.s.c.s.u.ConfigBuilder ] [main] - Parsed config file: { "env" : { "execution.parallelism" : 1, "job.mode" : "STREAMING", "job.name" : "##mysql_2_sr##", "checkpoint.interval" : 10000 }, "source" : [ { "base-url" : "jdbc:oracle:thin:flinkuser/[email protected]:1521/xamq", "password" : "mapapp", "debezium" : { "database.oracle.jdbc.timezoneAsRegion" : "false" }, "table-names" : [ "XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING" ], "result_table_name" : "mng_componentsmapping", "database-names" : [ "XAMQ" ], "schema-names" : [ "GRID_SYSDB" ], "source.reader.close.timeout" : 120000, "plugin_name" : "Oracle-CDC", "table-names-config" : [ { "table" : "XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING", "primaryKeys" : [ "CODE_ID" ] } ], "username" : "flinkuser" } ], "transform" : [ { "query" : "select * from mng_componentsmapping", "source_table_name" : "mng_componentsmapping", "result_table_name" : "mng_mapping", "plugin_name" : "sql" } ], "sink" : [ { "base-url" : "jdbc:mysql://172.18.xx.xx:9030", "savemode" : "KEEP_SCHEMA_AND_DATA", "password" : "root", "database" : "grid_city", "batch_max_rows" : 10, "starrocks.config" : { "format" : "JSON", "strip_outer_array" : true }, "nodeUrls" : [ "172.18.xx.xx:8030" ], "source_table_name" : [ "mng_mapping" ], "plugin_name" : "StarRocks", "table" : "mng_mapping", "username" : "root" } ] } 2024-03-22 15:57:01,590 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors 2024-03-22 15:57:01,593 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Oracle-CDC'} at: file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-cdc-oracle-2.3.4.jar 2024-03-22 15:57:01,594 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='StarRocks'} at: file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-starrocks-2.3.4.jar 2024-03-22 15:57:01,596 WARN [o.a.s.a.c.u.ConfigUtil ] [main] - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. 2024-03-22 15:57:01,602 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sources. 2024-03-22 15:57:01,881 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog Oracle established connection to jdbc:oracle:thin:flinkuser/[email protected]:1521/xamq 2024-03-22 15:57:02,523 INFO [o.a.s.a.t.c.CatalogTableUtil ] [main] - Get catalog tables, cost time: 893 2024-03-22 15:57:02,525 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [main] - Catalog Oracle closing 2024-03-22 15:57:02,554 INFO [.a.s.c.c.b.u.CatalogTableUtils] [main] - Override primary key([CODE_ID]) for catalog table XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING 2024-03-22 15:57:02,639 INFO [i.d.c.o.OracleConnection ] [main] - Database Version: Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production 2024-03-22 15:57:02,706 INFO [.s.c.o.u.OracleConnectionUtils] [main] - including 'XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING' for further processing 2024-03-22 15:57:02,709 INFO [i.d.j.JdbcConnection ] [pool-6-thread-1] - Connection gracefully closed 2024-03-22 15:57:02,727 INFO [i.d.c.o.OracleConnection ] [main] - Database Version: Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production 2024-03-22 15:57:02,809 INFO [.a.s.c.c.b.u.CatalogTableUtils] [main] - Override primary key([CODE_ID]) for catalog table XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING 2024-03-22 15:57:02,813 INFO [i.d.j.JdbcConnection ] [pool-7-thread-1] - Connection gracefully closed 2024-03-22 15:57:02,821 INFO [o.a.s.a.t.f.FactoryUtil ] [main] - get the CatalogTable from source Oracle-CDC: Oracle.XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING 2024-03-22 15:57:02,829 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSource Plugin from /opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors 2024-03-22 15:57:02,834 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Oracle-CDC'} at: file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-cdc-oracle-2.3.4.jar 2024-03-22 15:57:02,835 INFO [p.MultipleTableJobConfigParser] [main] - start generating all transforms. 2024-03-22 15:57:02,836 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelTransform Plugin from /opt/seatunnel/backend/apache-seatunnel-2.3.4/lib 2024-03-22 15:57:02,837 WARN [o.a.s.a.c.u.ConfigUtil ] [main] - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. 2024-03-22 15:57:02,844 WARN [o.a.s.a.c.u.ConfigUtil ] [main] - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. 2024-03-22 15:57:02,895 INFO [p.MultipleTableJobConfigParser] [main] - start generating all sinks. 2024-03-22 15:57:02,899 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Load SeaTunnelSink Plugin from /opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors 2024-03-22 15:57:02,899 INFO [.s.p.d.AbstractPluginDiscovery] [main] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='StarRocks'} at: file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-starrocks-2.3.4.jar 2024-03-22 15:57:03,097 INFO [o.a.s.c.s.s.c.StarRocksCatalog] [main] - Catalog StarRocks established connection to jdbc:mysql://172.18.13.47:9030 2024-03-22 15:57:03,141 INFO [o.a.s.c.s.s.c.StarRocksCatalog] [main] - Catalog StarRocks closing 2024-03-22 15:57:03,142 INFO [p.MultipleTableJobConfigParser] [main] - Unsupported multi table sink api, rollback to sink template 2024-03-22 15:57:03,185 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Start submit job, job id: 823465277835444225, with plugin jar [file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-starrocks-2.3.4.jar, file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-cdc-oracle-2.3.4.jar] 2024-03-22 15:57:03,192 INFO [.e.s.r.AbstractResourceManager] [hz.main.client.thread-4] - Init ResourceManager 2024-03-22 15:57:03,192 INFO [.e.s.r.AbstractResourceManager] [hz.main.client.thread-4] - initWorker... 2024-03-22 15:57:03,192 INFO [.e.s.r.AbstractResourceManager] [hz.main.client.thread-4] - initWorker live nodes: [[localhost]:5801] 2024-03-22 15:57:03,193 INFO [.e.s.r.AbstractResourceManager] [hz.main.client.thread-4] - registerWorker: {[localhost]:5801=WorkerProfile(address=[localhost]:5801, profile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=477626368}}, unassignedResource=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=477626368}}, assignedSlots=[], unassignedSlots=[])} 2024-03-22 15:57:03,207 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-0] - Init JobMaster for Job ##mysql_2_sr## (823465277835444225) 2024-03-22 15:57:03,207 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225) needed jar urls [file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-starrocks-2.3.4.jar, file:/opt/seatunnel/backend/apache-seatunnel-2.3.4/connectors/connector-cdc-oracle-2.3.4.jar] 2024-03-22 15:57:03,219 INFO [o.a.s.e.c.l.ClassLoaderUtil ] [seatunnel-coordinator-service-0] - recycle classloader org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader@7aead403 2024-03-22 15:57:03,412 WARN [o.a.h.u.NativeCodeLoader ] [seatunnel-coordinator-service-0] - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2024-03-22 15:57:03,501 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-0] - Create CheckpointCoordinator for job(1@823465277835444225) with plan(CheckpointPlan(pipelineId=1, pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}, taskID=50000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-sql]])=1, ActionStateKey(name=Ac tionStateKey - pipeline-1 [Source[0]-Oracle-CDC])=1}, subtaskActions={TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [TransformChain[Transform[0]-sql]]), 0), (ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Oracle-CDC]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}, taskID=50000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-StarRocks-XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Oracle-CDC]), -1)]})) 2024-03-22 15:57:03,502 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - The task Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)] is in state CREATED when init state future 2024-03-22 15:57:03,503 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - The task Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)] is in state CREATED when init state future 2024-03-22 15:57:03,504 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225) state process is start 2024-03-22 15:57:03,505 INFO [o.a.s.e.c.j.ClientJobProxy ] [main] - Submit job finished, job id: 823465277835444225, job name: SeaTunnel 2024-03-22 15:57:03,506 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225) turned from state CREATED to SCHEDULED. 2024-03-22 15:57:03,513 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)] state process is start 2024-03-22 15:57:03,516 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)] turned from state CREATED to SCHEDULED. 2024-03-22 15:57:03,532 WARN [o.a.s.e.c.j.JobMetricsRunner ] [job-metrics-runner-823465277835444225] - Failed to get job metrics summary, it maybe first-run 2024-03-22 15:57:03,534 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)] turned from state SCHEDULED to DEPLOYING. 2024-03-22 15:57:03,534 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)] state process is start 2024-03-22 15:57:03,536 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)] turned from state CREATED to DEPLOYING. 2024-03-22 15:57:03,544 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] received deploying task executionId [823465286458933249] 2024-03-22 15:57:03,552 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] deploying task TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}, executionId [823465286458933249] 2024-03-22 15:57:03,552 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] deploying TaskGroup TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1} init success 2024-03-22 15:57:03,557 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] deploying TaskGroup TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1} success 2024-03-22 15:57:03,559 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)] turned from state DEPLOYING to RUNNING. 2024-03-22 15:57:03,560 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SplitEnumerator (1/1)] current state equals target state: RUNNING, skip 2024-03-22 15:57:03,560 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)] state process is start 2024-03-22 15:57:03,561 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)] turned from state CREATED to DEPLOYING. 2024-03-22 15:57:03,571 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] received deploying task executionId [823465286458998785] 2024-03-22 15:57:03,577 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] deploying task TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}, executionId [823465286458998785] 2024-03-22 15:57:03,577 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] deploying TaskGroup TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000} init success 2024-03-22 15:57:03,578 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}] - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Oracle-CDC] 2024-03-22 15:57:03,589 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-0] - [localhost]:5801 [seatunnel-28537] [5.1] deploying TaskGroup TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000} success 2024-03-22 15:57:03,589 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}] - starting seatunnel transform task, index 0 2024-03-22 15:57:03,597 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)] turned from state DEPLOYING to RUNNING. 2024-03-22 15:57:03,597 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)] current state equals target state: RUNNING, skip 2024-03-22 15:57:03,599 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225), Pipeline: [(1/1)] turned from state DEPLOYING to RUNNING. 2024-03-22 15:57:03,607 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}] - starting seatunnel source task, index 0 2024-03-22 15:57:03,610 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-0] - Job ##mysql_2_sr## (823465277835444225) turned from state SCHEDULED to RUNNING. 2024-03-22 15:57:03,630 INFO [i.d.c.o.OracleConnection ] [hz.main.seaTunnel.task.thread-5] - Database Version: Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production 2024-03-22 15:57:03,677 INFO [.s.c.o.u.OracleConnectionUtils] [hz.main.seaTunnel.task.thread-5] - including 'XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING' for further processing 2024-03-22 15:57:03,680 INFO [i.d.j.JdbcConnection ] [pool-11-thread-1] - Connection gracefully closed 2024-03-22 15:57:03,720 INFO [a.s.c.s.c.s.r.SourceReaderBase] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}] - Open Source Reader. 2024-03-22 15:57:03,722 INFO [.s.t.SourceSplitEnumeratorTask] [hz.main.seaTunnel.task.thread-4] - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2024-03-22 15:57:03,742 INFO [i.d.c.o.OracleConnection ] [hz.main.seaTunnel.task.thread-5] - Database Version: Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production 2024-03-22 15:57:03,744 INFO [i.d.j.JdbcConnection ] [pool-13-thread-1] - Connection gracefully closed 2024-03-22 15:57:03,748 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.seaTunnel.task.thread-5] - SnapshotSplitAssigner created with remaining tables: [XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING] 2024-03-22 15:57:03,749 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.seaTunnel.task.thread-5] - SnapshotSplitAssigner created with remaining splits: [] 2024-03-22 15:57:03,749 INFO [.c.b.s.e.SnapshotSplitAssigner] [hz.main.seaTunnel.task.thread-5] - SnapshotSplitAssigner created with assigned splits: [] 2024-03-22 15:57:03,803 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-1] - checkpoint is enabled, start schedule trigger pending checkpoint. 2024-03-22 15:57:03,895 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}] - received enough reader, starting enumerator... 2024-03-22 15:57:03,909 INFO [i.d.c.o.OracleConnection ] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}] - Database Version: Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production 2024-03-22 15:57:03,909 INFO [bstractJdbcSourceChunkSplitter] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}] - Start splitting table XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING into chunks... 2024-03-22 15:57:03,912 INFO [i.d.j.JdbcConnection ] [pool-14-thread-1] - Connection gracefully closed 2024-03-22 15:57:03,914 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=823465277835444225, pipelineId=1, taskGroupId=1}] - [localhost]:5801 [seatunnel-28537] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@60fdcc35 java.lang.RuntimeException: Generate Splits for table XAMQ.GRID_SYSDB.MNG_COMPONENTSMAPPING error at org.apache.seatunnel.connectors.cdc.base.source.enumerator.splitter.AbstractJdbcSourceChunkSplitter.generateSplits(AbstractJdbcSourceChunkSplitter.java:112) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.connectors.cdc.base.source.enumerator.SnapshotSplitAssigner.getNext(SnapshotSplitAssigner.java:181) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.connectors.cdc.base.source.enumerator.HybridSplitAssigner.getNext(HybridSplitAssigner.java:94) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator.assignSplits(IncrementalSourceEnumerator.java:160) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator.run(IncrementalSourceEnumerator.java:69) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:307) ~[seatunnel-starter.jar:2.3.4] at org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134) ~[seatunnel-starter.jar:2.3.4] at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:643) [seatunnel-starter.jar:2.3.4] at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:944) [seatunnel-starter.jar:2.3.4] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_391] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_391] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_391] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_391] Caused by: java.lang.NullPointerException at org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.OracleDialect.getPrimaryKey(OracleDialect.java:136) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.connectors.cdc.base.source.enumerator.splitter.AbstractJdbcSourceChunkSplitter.getSplitColumn(AbstractJdbcSourceChunkSplitter.java:384) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] at org.apache.seatunnel.connectors.cdc.base.source.enumerator.splitter.AbstractJdbcSourceChunkSplitter.generateSplits(AbstractJdbcSourceChunkSplitter.java:64) ~[connector-cdc-oracle-2.3.4.jar:2.3.4] ... 13 more ``` ### Zeta or Flink or Spark Version - ### Java or Scala Version java 1.8.0_391 ### Screenshots  ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
