fanxishu opened a new issue, #7412: URL: https://github.com/apache/seatunnel/issues/7412
### 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    web点击执行直接执行插入错误的语句 ### SeaTunnel Version 3.3.6 ### SeaTunnel Config ```conf env { "job.mode"=BATCH "job.name"="SeaTunnel_Job" "savemode.execute.location"=CLUSTER } source { Jdbc { "connection_check_timeout_sec"=30 "use_select_count"="false" "skip_analyze"="false" "split.size"=8096 "split.even-distribution.factor.upper-bound"=100 "split.even-distribution.factor.lower-bound"=0.05 "split.sample-sharding.threshold"=1000 "split.inverse-sampling.rate"=1000 parallelism=1 "result_table_name"=Table14617227625728 query="SELECT `id`, `type`, `role_name`, `description`, `create_time`, `update_time` FROM `seatunnel`.`role`" password="123456" url="jdbc:mysql://127.0.0.1:3380/test1?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true" driver="com.mysql.cj.jdbc.Driver" user=root } } transform { } sink { Jdbc { "schema_save_mode"="CREATE_SCHEMA_WHEN_NOT_EXIST" "data_save_mode"="APPEND_DATA" "connection_check_timeout_sec"=30 "batch_size"=1000 "is_exactly_once"="false" "max_commit_attempts"=3 "transaction_timeout_sec"=-1 "max_retries"="3" "auto_commit"="true" "support_upsert_by_query_primary_key_exist"="false" "multi_table_sink_replica"=1 "source_table_name"=Table14617227625728 "generate_sink_sql"=true database=test3 table=role password="123456" url="jdbc:mysql://127.0.0.1:3380/test1?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true" driver="com.mysql.cj.jdbc.Driver" user=root } } ``` ### Running Command ```shell 我点击执行页面的时候结果去执行插入角色表数据的时候直接插入的是用户表的字段了 ``` ### Error Exception ```log seatuuul执行的日志 2024-08-15 15:23:58,927 INFO [.p.t.AuthenticationMessageTask] [hz.main.priority-generic-operation.thread-0] - [localhost]:5801 [seatunnel] [5.1] Received auth from Connection[id=35, /127.0.0.1:5801->/127.0.0.1:37954, qualifier=null, endpoint=[127.0.0.1]:37954, remoteUuid=b0a39238-e4be-4175-82bd-8ecd40f8864d, alive=true, connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid: b0a39238-e4be-4175-82bd-8ecd40f8864d, client name: hz.client_35, client version: 5.1 2024-08-15 15:23:59,035 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-5] - in batch mode, the 'checkpoint.interval' configuration of env is missing, so checkpoint will be disabled 2024-08-15 15:23:59,035 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-5] - Init JobMaster for Job 14627358579200_job (876365590837592065) 2024-08-15 15:23:59,035 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065) needed jar urls [file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar] 2024-08-15 15:23:59,035 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-5] - Create classloader for job 876365590837592065 with jars [file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar] 2024-08-15 15:23:59,076 INFO [o.a.s.c.s.j.c.m.MySqlCatalog ] [seatunnel-coordinator-service-5] - Failed to get mysql version, fallback to default version: V_5_7 java.lang.UnsupportedOperationException: Unsupported MySQL version: 8.3.0 at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.mysql.MySqlVersion.parse(MySqlVersion.java:45) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog.resolveVersion(MySqlCatalog.java:211) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog.<init>(MySqlCatalog.java:67) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalogFactory.createCatalog(MySqlCatalogFactory.java:53) ~[?:?] at org.apache.seatunnel.api.table.factory.FactoryUtil.lambda$createOptionalCatalog$0(FactoryUtil.java:174) ~[seatunnel-starter.jar:2.3.6] at java.util.Optional.map(Optional.java:215) ~[?:1.8.0_191] at org.apache.seatunnel.api.table.factory.FactoryUtil.createOptionalCatalog(FactoryUtil.java:173) ~[seatunnel-starter.jar:2.3.6] at org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils.findCatalog(JdbcCatalogUtils.java:382) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSink.getSaveModeHandler(JdbcSink.java:197) ~[?:?] at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:370) ~[seatunnel-starter.jar:2.3.6] at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:381) ~[seatunnel-starter.jar:2.3.6] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184) ~[?:1.8.0_191] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_191] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) ~[?:1.8.0_191] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_191] at java.util.Iterator.forEachRemaining(Iterator.java:116) ~[?:1.8.0_191] at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) ~[?:1.8.0_191] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[?:1.8.0_191] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[?:1.8.0_191] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151) ~[?:1.8.0_191] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174) ~[?:1.8.0_191] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_191] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418) ~[?:1.8.0_191] at org.apache.seatunnel.engine.server.master.JobMaster.init(JobMaster.java:240) ~[seatunnel-starter.jar:2.3.6] at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$4(CoordinatorService.java:499) ~[seatunnel-starter.jar:2.3.6] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] 2024-08-15 15:23:59,078 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-5] - Catalog MySQL established connection to jdbc:mysql://127.0.0.1:3380/test1?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true 2024-08-15 15:23:59,080 INFO [a.s.a.s.SaveModeExecuteWrapper] [seatunnel-coordinator-service-5] - Executing save mode for table: test3.role, with SchemaSaveMode: CREATE_SCHEMA_WHEN_NOT_EXIST, DataSaveMode: APPEND_DATA using Catalog: MySQL 2024-08-15 15:23:59,097 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-5] - Catalog MySQL closing 2024-08-15 15:23:59,102 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-5] - Release classloader for job 876365590837592065 with jars [file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar] 2024-08-15 15:23:59,110 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-5] - Create CheckpointCoordinator for job(1@876365590837592065) with plan(CheckpointPlan(pipelineId=1, pipelineSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}, taskID=50000, index=0}, TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], startingSubtasks=[TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}], pipelineActions={ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc])=1, ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Jdbc-MultiTableSink])=1}, subtaskActions={TaskLocation{taskGroupLocation=TaskGroupLocation{jo bId=876365590837592065, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}, taskID=50000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Sink[0]-Jdbc-MultiTableSink]), 0)], TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}, taskID=20000, index=0}=[(ActionStateKey(name=ActionStateKey - pipeline-1 [Source[0]-Jdbc]), -1)]})) 2024-08-15 15:23:59,110 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - The task Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] is in state CREATED when init state future 2024-08-15 15:23:59,110 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - The task Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] is in state CREATED when init state future 2024-08-15 15:23:59,110 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065) state process is start 2024-08-15 15:23:59,111 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065) turned from state CREATED to SCHEDULED. 2024-08-15 15:23:59,111 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)] state process is start 2024-08-15 15:23:59,112 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)] turned from state CREATED to SCHEDULED. 2024-08-15 15:23:59,113 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)] turned from state SCHEDULED to DEPLOYING. 2024-08-15 15:23:59,113 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] state process is start 2024-08-15 15:23:59,114 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] turned from state CREATED to DEPLOYING. 2024-08-15 15:23:59,115 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] received deploying task executionId [876365022048550913] 2024-08-15 15:23:59,115 INFO [.c.c.DefaultClassLoaderService] [seatunnel-coordinator-service-5] - Create classloader for job 876365590837592065 with jars [file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar] 2024-08-15 15:23:59,123 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] deploying task TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}, executionId [876365022048550913] 2024-08-15 15:23:59,123 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1} init success 2024-08-15 15:23:59,124 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1} success 2024-08-15 15:23:59,125 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - starting seatunnel source split enumerator task, source name: pipeline-1 [Source[0]-Jdbc] 2024-08-15 15:23:59,126 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] turned from state DEPLOYING to RUNNING. 2024-08-15 15:23:59,126 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SplitEnumerator (1/1)] current state equals target state: RUNNING, skip 2024-08-15 15:23:59,126 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] state process is start 2024-08-15 15:23:59,126 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] turned from state CREATED to DEPLOYING. 2024-08-15 15:23:59,128 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] received deploying task executionId [876365022048616449] 2024-08-15 15:23:59,143 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [hz.main.seaTunnel.task.thread-7] - Switch to dynamic chunk splitter 2024-08-15 15:23:59,148 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] deploying task TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}, executionId [876365022048616449] 2024-08-15 15:23:59,148 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000} init success 2024-08-15 15:23:59,156 INFO [s.e.s.t.TransformSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}] - starting seatunnel transform task, index 0 2024-08-15 15:23:59,156 INFO [o.a.s.e.s.TaskExecutionService] [seatunnel-coordinator-service-5] - [localhost]:5801 [seatunnel] [5.1] deploying TaskGroup TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000} success 2024-08-15 15:23:59,158 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}] - Switch to dynamic chunk splitter 2024-08-15 15:23:59,160 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] turned from state DEPLOYING to RUNNING. 2024-08-15 15:23:59,160 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc]-SourceTask (1/1)] current state equals target state: RUNNING, skip 2024-08-15 15:23:59,161 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065), Pipeline: [(1/1)] turned from state DEPLOYING to RUNNING. 2024-08-15 15:23:59,161 INFO [o.a.s.e.s.d.p.PhysicalPlan ] [seatunnel-coordinator-service-5] - Job 14627358579200_job (876365590837592065) turned from state SCHEDULED to RUNNING. 2024-08-15 15:23:59,165 INFO [a.s.a.s.m.MultiTableSinkWriter] [hz.main.seaTunnel.task.thread-7] - init multi table sink writer, queue size: 1 2024-08-15 15:23:59,170 INFO [.a.s.e.s.t.SourceSeaTunnelTask] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}] - starting seatunnel source task, index 0 2024-08-15 15:23:59,174 INFO [.s.t.SourceSplitEnumeratorTask] [hz.main.seaTunnel.task.thread-7] - received reader register, readerID: TaskLocation{taskGroupLocation=TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}, taskID=40000, index=0} 2024-08-15 15:23:59,174 INFO [.j.s.JdbcSourceSplitEnumerator] [hz.main.seaTunnel.task.thread-7] - Register reader 0 to JdbcSourceSplitEnumerator. 2024-08-15 15:23:59,263 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-6] - checkpoint is disabled, because in batch mode and 'checkpoint.interval' of env is missing. 2024-08-15 15:23:59,326 INFO [.s.t.SourceSplitEnumeratorTask] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - received enough reader, starting enumerator... 2024-08-15 15:23:59,326 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - Starting split enumerator. 2024-08-15 15:23:59,326 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - Splitting table default.default.default. 2024-08-15 15:23:59,326 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - Start splitting table default.default.default into chunks... 2024-08-15 15:23:59,327 WARN [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - No split key found for table default.default.default 2024-08-15 15:23:59,328 INFO [o.a.s.c.s.j.s.ChunkSplitter ] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - Split table default.default.default into 1 chunks, time cost: 2ms. 2024-08-15 15:23:59,328 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - Split table default.default.default into 1 splits. 2024-08-15 15:23:59,329 INFO [.j.s.JdbcSourceSplitEnumerator] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=1}] - No more splits to assign. Sending NoMoreSplitsEvent to reader [0]. 2024-08-15 15:24:00,297 INFO [o.a.s.c.s.j.s.JdbcSourceReader] [BlockingWorker-TaskGroupLocation{jobId=876365590837592065, pipelineId=1, taskGroupId=30000}] - Closed the bounded jdbc source 2024-08-15 15:24:00,297 WARN [o.a.s.s.c.z.h.HikariConfig ] [st-multi-table-sink-writer-1] - HikariPool-5 - idleTimeout has been set but has no effect because the pool is operating as a fixed size pool. 2024-08-15 15:24:00,297 INFO [o.a.s.s.c.z.h.HikariDataSource] [st-multi-table-sink-writer-1] - HikariPool-5 - Starting... 2024-08-15 15:24:00,320 INFO [o.a.s.s.c.z.h.HikariDataSource] [st-multi-table-sink-writer-1] - HikariPool-5 - Start completed. 2024-08-15 15:24:00,327 INFO [.e.FieldNamedPreparedStatement] [st-multi-table-sink-writer-1] - PrepareStatement sql is: INSERT INTO `test3`.`role` (`id`, `username`, `password`, `status`, `type`, `create_time`, `update_time`) VALUES (?, ?, ?, ?, ?, ?, ?) 2024-08-15 15:24:00,332 INFO [.s.e.s.c.CheckpointCoordinator] [seatunnel-coordinator-service-6] - wait checkpoint completed: 9223372036854775807 2024-08-15 15:24:00,339 ERROR [o.a.s.c.s.j.i.JdbcOutputFormat] [st-multi-table-sink-writer-2] - JDBC executeBatch error, retry times = 0 java.sql.BatchUpdateException: Unknown column 'username' in 'field list' at sun.reflect.GeneratedConstructorAccessor32.newInstance(Unknown Source) ~[?:?] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_191] at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_191] at com.mysql.cj.util.Util.handleNewInstance(Util.java:192) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:167) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:174) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLError.createBatchUpdateException(SQLError.java:224) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:755) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchInternal(ClientPreparedStatement.java:426) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.StatementImpl.executeBatch(StatementImpl.java:800) ~[mysql-connector-java-8.0.27.jar:8.0.27] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.ProxyStatement.executeBatch(ProxyStatement.java:127) ~[?:?] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeBatch(HikariProxyPreparedStatement.java) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:534) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:51) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferedBatchStatementExecutor.executeBatch(BufferedBatchStatementExecutor.java:53) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:172) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:136) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.prepareCommit(JdbcSinkWriter.java:131) ~[?:?] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.lambda$prepareCommit$4(MultiTableSinkWriter.java:217) ~[seatunnel-starter.jar:2.3.6] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] Caused by: java.sql.SQLSyntaxErrorException: Unknown column 'username' in 'field list' at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:953) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1098) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1046) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeLargeUpdate(ClientPreparedStatement.java:1371) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:716) ~[mysql-connector-java-8.0.27.jar:8.0.27] ... 16 more 2024-08-15 15:24:00,344 ERROR [o.a.s.c.s.j.i.JdbcOutputFormat] [st-multi-table-sink-writer-2] - JDBC executeBatch error, retry times = 1 java.sql.BatchUpdateException: Unknown column 'username' in 'field list' at sun.reflect.GeneratedConstructorAccessor32.newInstance(Unknown Source) ~[?:?] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_191] at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_191] at com.mysql.cj.util.Util.handleNewInstance(Util.java:192) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:167) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:174) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLError.createBatchUpdateException(SQLError.java:224) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:755) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchInternal(ClientPreparedStatement.java:426) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.StatementImpl.executeBatch(StatementImpl.java:800) ~[mysql-connector-java-8.0.27.jar:8.0.27] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.ProxyStatement.executeBatch(ProxyStatement.java:127) ~[?:?] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeBatch(HikariProxyPreparedStatement.java) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:534) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:51) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferedBatchStatementExecutor.executeBatch(BufferedBatchStatementExecutor.java:53) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:172) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:136) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.prepareCommit(JdbcSinkWriter.java:131) ~[?:?] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.lambda$prepareCommit$4(MultiTableSinkWriter.java:217) ~[seatunnel-starter.jar:2.3.6] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] Caused by: java.sql.SQLSyntaxErrorException: Unknown column 'username' in 'field list' at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:953) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1098) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1046) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeLargeUpdate(ClientPreparedStatement.java:1371) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:716) ~[mysql-connector-java-8.0.27.jar:8.0.27] ... 16 more 2024-08-15 15:24:01,347 ERROR [o.a.s.c.s.j.i.JdbcOutputFormat] [st-multi-table-sink-writer-2] - JDBC executeBatch error, retry times = 2 java.sql.BatchUpdateException: Unknown column 'username' in 'field list' at sun.reflect.GeneratedConstructorAccessor32.newInstance(Unknown Source) ~[?:?] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_191] at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_191] at com.mysql.cj.util.Util.handleNewInstance(Util.java:192) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:167) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:174) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLError.createBatchUpdateException(SQLError.java:224) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:755) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchInternal(ClientPreparedStatement.java:426) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.StatementImpl.executeBatch(StatementImpl.java:800) ~[mysql-connector-java-8.0.27.jar:8.0.27] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.ProxyStatement.executeBatch(ProxyStatement.java:127) ~[?:?] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeBatch(HikariProxyPreparedStatement.java) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:534) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:51) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferedBatchStatementExecutor.executeBatch(BufferedBatchStatementExecutor.java:53) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:172) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:136) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.prepareCommit(JdbcSinkWriter.java:131) ~[?:?] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.lambda$prepareCommit$4(MultiTableSinkWriter.java:217) ~[seatunnel-starter.jar:2.3.6] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] Caused by: java.sql.SQLSyntaxErrorException: Unknown column 'username' in 'field list' at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:953) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1098) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1046) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeLargeUpdate(ClientPreparedStatement.java:1371) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:716) ~[mysql-connector-java-8.0.27.jar:8.0.27] ... 16 more 2024-08-15 15:24:03,351 ERROR [o.a.s.c.s.j.i.JdbcOutputFormat] [st-multi-table-sink-writer-2] - JDBC executeBatch error, retry times = 3 java.sql.BatchUpdateException: Unknown column 'username' in 'field list' at sun.reflect.GeneratedConstructorAccessor32.newInstance(Unknown Source) ~[?:?] at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_191] at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_191] at com.mysql.cj.util.Util.handleNewInstance(Util.java:192) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:167) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.util.Util.getInstance(Util.java:174) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLError.createBatchUpdateException(SQLError.java:224) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:755) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchInternal(ClientPreparedStatement.java:426) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.StatementImpl.executeBatch(StatementImpl.java:800) ~[mysql-connector-java-8.0.27.jar:8.0.27] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.ProxyStatement.executeBatch(ProxyStatement.java:127) ~[?:?] at org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeBatch(HikariProxyPreparedStatement.java) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:534) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:51) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferedBatchStatementExecutor.executeBatch(BufferedBatchStatementExecutor.java:53) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:172) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:136) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.prepareCommit(JdbcSinkWriter.java:131) ~[?:?] at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.lambda$prepareCommit$4(MultiTableSinkWriter.java:217) ~[seatunnel-starter.jar:2.3.6] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] Caused by: java.sql.SQLSyntaxErrorException: Unknown column 'username' in 'field list' at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:953) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1098) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeUpdateInternal(ClientPreparedStatement.java:1046) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeLargeUpdate(ClientPreparedStatement.java:1371) ~[mysql-connector-java-8.0.27.jar:8.0.27] at com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchedInserts(ClientPreparedStatement.java:716) ~[mysql-connector-java-8.0.27.jar:8.0.27] ... 16 more web执行的日志： 2024-08-15 16:39:44.939 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [SeatunnelPermissionServiceImpl.funcPermissionCheck():38] - func permission check in seatunnel 2024-08-15 16:39:44.940 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [JobInstanceServiceImpl.createExecuteResource():130] - receive createExecuteResource request, userId:2, jobDefineId:14605812455584 2024-08-15 16:39:45.001 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [SeatunnelPermissionServiceImpl.funcPermissionCheck():38] - func permission check in seatunnel 2024-08-15 16:39:45.221 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [SeatunnelPermissionServiceImpl.funcPermissionCheck():38] - func permission check in seatunnel 2024-08-15 16:39:45.230 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [SeatunnelPermissionServiceImpl.funcPermissionCheck():38] - func permission check in seatunnel 2024-08-15 16:39:45.261 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [SeatunnelPermissionServiceImpl.funcPermissionCheck():38] - func permission check in seatunnel 2024-08-15 16:39:45.296 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [JobExecutorServiceImpl.writeJobConfigIntoConfFile():96] - File created and content written successfully. Aug 15, 2024 4:39:45 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'hazelcast-client.yaml' from the classpath. 2024-08-15 16:39:45.306 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] Running with 2 response threads, dynamic=true 2024-08-15 16:39:45.308 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING 2024-08-15 16:39:45.309 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED 2024-08-15 16:39:45.310 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] Trying to connect to cluster: seatunnel 2024-08-15 16:39:45.311 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] Trying to connect to [localhost]:5801 2024-08-15 16:39:45.318 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_CONNECTED 2024-08-15 16:39:45.318 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] Authenticated with server [localhost]:5801:e12041c0-446c-4dc9-8f65-af10a4336bab, server version: 5.1, local address: /127.0.0.1:33295 2024-08-15 16:39:45.318 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. 2024-08-15 16:39:45.320 seatunnel host-10-19-11-19 INFO [tr:,sp:] [hz.client_2.event-9] [ClientLoggingService$DefaultLogger.log():104] - hz.client_2 [seatunnel] [5.1] Members [1] { Member [localhost]:5801 - e12041c0-446c-4dc9-8f65-af10a4336bab } 2024-08-15 16:39:45.323 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractLogger.info():69] - Client statistics is enabled with period 5 seconds. Aug 15, 2024 4:39:45 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'seatunnel.yaml' from the classpath. 2024-08-15 16:39:45.330 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractLogger.info():69] - seatunnel.home is /app01/seatuunel/apache-seatunnel-web-1.0.0-SNAPSHOT Aug 15, 2024 4:39:45 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'hazelcast.yaml' from the classpath. 2024-08-15 16:39:45.418 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ConfigBuilder.of():73] - Loading config file from path: /app01/seatuunel/apache-seatunnel-web-1.0.0-SNAPSHOT/profile/14605812455584.conf 2024-08-15 16:39:45.425 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [ConfigShadeUtils.<clinit>():64] - Load config shade spi: [base64] 2024-08-15 16:39:45.451 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [MultipleTableJobConfigParser.fillJobConfigAndCommonJars():303] - add common jar in plugins :[] 2024-08-15 16:39:45.455 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.<init>():113] - Load SeaTunnelSink Plugin from /app01/seatuunel/apache-seatunnel-2.3.6/connectors 2024-08-15 16:39:45.456 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.findPluginJarPath():444] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} at: file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar 2024-08-15 16:39:45.456 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.findPluginJarPath():444] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Jdbc'} at: file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar 2024-08-15 16:39:45.458 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [ConfigUtil.convertValue():64] - 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-08-15 16:39:45.459 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [MultipleTableJobConfigParser.parse():205] - start generating all sources. 2024-08-15 16:39:45.726 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [MySqlCatalog.resolveVersion():213] - Failed to get mysql version, fallback to default version: V_5_7 java.lang.UnsupportedOperationException: Unsupported MySQL version: 8.3.0 at org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.mysql.MySqlVersion.parse(MySqlVersion.java:45) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog.resolveVersion(MySqlCatalog.java:211) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog.<init>(MySqlCatalog.java:67) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalogFactory.createCatalog(MySqlCatalogFactory.java:53) at org.apache.seatunnel.api.table.factory.FactoryUtil.lambda$createOptionalCatalog$0(FactoryUtil.java:175) at java.util.Optional.map(Optional.java:215) at org.apache.seatunnel.api.table.factory.FactoryUtil.createOptionalCatalog(FactoryUtil.java:174) at org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils.findCatalog(JdbcCatalogUtils.java:382) at org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils.getTables(JdbcCatalogUtils.java:73) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.<init>(JdbcSource.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceFactory.lambda$createSource$0(JdbcSourceFactory.java:80) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:114) at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:74) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:361) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.app.service.impl.JobExecutorServiceImpl.executeJobBySeaTunnel(JobExecutorServiceImpl.java:112) at org.apache.seatunnel.app.service.impl.JobExecutorServiceImpl.jobExecute(JobExecutorServiceImpl.java:76) at org.apache.seatunnel.app.controller.JobExecutorController.jobExecutor(JobExecutorController.java:55) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808) at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1067) at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963) at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) at javax.servlet.http.HttpServlet.service(HttpServlet.java:497) at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) at javax.servlet.http.HttpServlet.service(HttpServlet.java:584) at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) at org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1631) at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193) at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601) at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193) at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601) at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193) at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1601) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:548) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143) at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:600) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) at org.eclipse.jetty.server.Server.handle(Server.java:516) at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) at java.lang.Thread.run(Thread.java:748) 2024-08-15 16:39:45.728 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [JdbcCatalogUtils.getTables():76] - Loading catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog 2024-08-15 16:39:45.728 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractJdbcCatalog.open():130] - Catalog MySQL established connection to jdbc:mysql://127.0.0.1:3380/test1?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true 2024-08-15 16:39:45.741 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [JdbcCatalogUtils.getTables():118] - Loaded 1 catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.mysql.MySqlCatalog 2024-08-15 16:39:45.742 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractJdbcCatalog.close():144] - Catalog MySQL closing 2024-08-15 16:39:45.743 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [FactoryUtil.createAndPrepareSource():86] - get the CatalogTable from source Jdbc: jdbc_catalog.default.default.default 2024-08-15 16:39:45.756 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.<init>():113] - Load SeaTunnelSource Plugin from /app01/seatuunel/apache-seatunnel-2.3.6/connectors 2024-08-15 16:39:45.757 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.findPluginJarPath():444] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} at: file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar 2024-08-15 16:39:45.760 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [MultipleTableJobConfigParser.parse():213] - start generating all transforms. 2024-08-15 16:39:45.762 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [MultipleTableJobConfigParser.parse():216] - start generating all sinks. 2024-08-15 16:39:45.763 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-19] [ConfigUtil.convertValue():64] - 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-08-15 16:39:45.766 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.<init>():113] - Load SeaTunnelSink Plugin from /app01/seatuunel/apache-seatunnel-2.3.6/connectors 2024-08-15 16:39:45.766 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractPluginDiscovery.findPluginJarPath():444] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Jdbc'} at: file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar 2024-08-15 16:39:45.771 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [FactoryUtil.createAndPrepareSink():134] - Create sink 'Jdbc' with upstream input catalog-table[database: default, schema: default, table: default] 2024-08-15 16:39:45.830 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractLogger.info():69] - Start submit job, job id: 876384660119093249, with plugin jar [file:/app01/seatuunel/apache-seatunnel-2.3.6/connectors/connector-jdbc-2.3.6.jar] 2024-08-15 16:39:45.906 seatunnel host-10-19-11-19 INFO [tr:,sp:] [qtp431939256-19] [AbstractLogger.info():69] - Submit job finished, job id: 876384660119093249, job name: 14627940514688_job 2024-08-15 16:39:45.942 seatunnel host-10-19-11-19 INFO [tr:,sp:] [ForkJoinPool.commonPool-worker-3] [JobExecutorServiceImpl.waitJobFinish():144] - future.get before 2024-08-15 16:39:46.020 seatunnel host-10-19-11-19 WARN [tr:,sp:] [qtp431939256-18] [SeatunnelPermissionServiceImpl.funcPermissionCheck():38] - func permission check in seatunnel ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
