gphwxhq opened a new issue, #10343: URL: https://github.com/apache/seatunnel/issues/10343
### 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 It seems that the tableId of the error table has not been processed correctly <img width="1073" height="767" alt="Image" src="https://github.com/user-attachments/assets/7a6339d8-10f5-4b70-914c-80408ba4e3fa"; /> ### SeaTunnel Version 2.3.12 ### SeaTunnel Config ```conf { "env" : { "parallelism" : 1, "job.mode" : "BATCH" }, "source" : [ { "use_select_count" : false, "split.string_split_mode" : "sample", "split.even-distribution.factor.upper-bound" : 100, "split.sample-sharding.threshold" : 1000, "connection_check_timeout_sec" : 30, "fetch_size" : 0, "use_regex" : false, "split.size" : 8096, "split.inverse-sampling.rate" : 1000, "int_type_narrowing" : true, "split.even-distribution.factor.lower-bound" : 0.05, "decimal_type_narrowing" : true, "skip_analyze" : false, "plugin_output" : "Table176767047697855e", "query" : "SELECT `id`, `name`, `address`, `time` FROM `table`.`source`", "password" : "******", "url" : "jdbc:mysql://192.168.127.129:3306/seatunnel?useUnicode=true&serverTimezone=Asia/Shanghai&characterEncoding=UTF-8&useSSL=false&", "driver" : "com.mysql.cj.jdbc.Driver", "username" : "******", "plugin_name" : "Jdbc" } ], "transform" : [ { "row_error_handle_way" : "ROUTE_TO_TABLE", "field_rules" : [ { "field_name" : "name", "rules" : [ { "rule_type" : "NOT_NULL", "custom_message" : "姓名是必需的" }, { "rule_type" : "LENGTH", "min_length" : 2, "max_length" : 50, "custom_message" : "姓名长度必须在2到50个字符之间" } ] } ], "row_error_handle_way.error_table" : "ffp", "plugin_output" : "Table17676705073592y9", "plugin_input" : "Table176767047697855e", "plugin_name" : "DataValidator" } ], "sink" : [ { "is_primary_key_updated" : true, "batch_size" : 1000, "max_retries" : 0, "create_index" : true, "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "auto_commit" : true, "field_ide" : null, "max_commit_attempts" : 3, "use_copy_statement" : false, "is_exactly_once" : false, "support_upsert_by_insert_only" : false, "enable_upsert" : true, "transaction_timeout_sec" : -1, "data_save_mode" : "DROP_DATA", "connection_check_timeout_sec" : 30, "multi_table_sink_replica" : 1, "plugin_input" : "Table17676705073592y9", "generate_sink_sql" : true, "database" : "table2", "password" : "******", "url" : "jdbc:mysql://192.168.127.129:3306/seatunnel?useUnicode=true&serverTimezone=Asia/Shanghai&characterEncoding=UTF-8&useSSL=false&", "driver" : "com.mysql.cj.jdbc.Driver", "username" : "******", "plugin_name" : "Jdbc" } ] } ``` ### Running Command ```shell by RESTful ``` ### Error Exception ```log =============================================================================== [] 2026-01-15 08:55:29,481 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, [] 2026-01-15 08:55:29,481 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues [] 2026-01-15 08:55:29,481 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:SeaTunnel job executed failed [] 2026-01-15 08:55:29,484 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:226) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.example.engine.SeaTunnelEngineLocalExample.main(SeaTunnelEngineLocalExample.java:48) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: java.lang.RuntimeException: java.lang.RuntimeException: multi table sink can not write table: ffp at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:303) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) 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:82) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:56) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:683) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1012) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) at java.util.concurrent.FutureTask.run(FutureTask.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.FutureTask.<init>(FutureTask.java:151) at java.util.concurrent.AbstractExecutorService.newTaskFor(AbstractExecutorService.java:87) at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:111) at org.apache.seatunnel.api.tracing.MDCExecutorService.submit(MDCExecutorService.java:78) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) at org.apache.seatunnel.engine.server.TaskExecutionService.submitBlockingTask(TaskExecutionService.java:255) at org.apache.seatunnel.engine.server.TaskExecutionService.deployLocalTask(TaskExecutionService.java:405) at org.apache.seatunnel.engine.server.TaskExecutionService.deployTask(TaskExecutionService.java:340) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.lambda$deployOnLocal$0(PhysicalVertex.java:269) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.deployInternal(PhysicalVertex.java:324) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.deployOnLocal(PhysicalVertex.java:263) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.deploy(PhysicalVertex.java:311) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.stateProcess(PhysicalVertex.java:558) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.updateTaskState(PhysicalVertex.java:390) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.makeTaskGroupDeploy(PhysicalVertex.java:304) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$stateProcess$21(SubPlan.java:673) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:669) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:655) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:624) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.startSubPlanStateProcess(SubPlan.java:608) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.restorePipeline(SubPlan.java:496) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:699) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$4(SubPlan.java:228) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.CompletableFuture$UniAccept.<init>(CompletableFuture.java:641) at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:684) at java.util.concurrent.CompletableFuture.thenAcceptAsync(CompletableFuture.java:2019) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.addPhysicalVertexCallBack(SubPlan.java:198) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$initStateFuture$3(SubPlan.java:189) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.initStateFuture(SubPlan.java:187) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.addPipelineEndCallback(PhysicalPlan.java:145) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.prepareRestorePipeline(SubPlan.java:472) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:696) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$4(SubPlan.java:228) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.CompletableFuture$UniAccept.<init>(CompletableFuture.java:641) at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:684) at java.util.concurrent.CompletableFuture.thenAcceptAsync(CompletableFuture.java:2019) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.addPhysicalVertexCallBack(SubPlan.java:198) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$initStateFuture$3(SubPlan.java:189) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.initStateFuture(SubPlan.java:187) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.addPipelineEndCallback(PhysicalPlan.java:145) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.prepareRestorePipeline(SubPlan.java:472) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:696) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$4(SubPlan.java:228) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.CompletableFuture$UniAccept.<init>(CompletableFuture.java:641) at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:684) at java.util.concurrent.CompletableFuture.thenAcceptAsync(CompletableFuture.java:2019) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.addPhysicalVertexCallBack(SubPlan.java:198) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$initStateFuture$3(SubPlan.java:189) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.initStateFuture(SubPlan.java:187) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.addPipelineEndCallback(PhysicalPlan.java:145) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.initStateFuture(PhysicalPlan.java:140) at org.apache.seatunnel.engine.server.master.JobMaster.initStateFuture(JobMaster.java:371) at org.apache.seatunnel.engine.server.master.JobMaster.init(JobMaster.java:305) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:646) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) at java.util.concurrent.FutureTask.run(FutureTask.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.FutureTask.<init>(FutureTask.java:151) at java.util.concurrent.AbstractExecutorService.newTaskFor(AbstractExecutorService.java:87) at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:111) at org.apache.seatunnel.api.tracing.MDCExecutorService.submit(MDCExecutorService.java:78) at org.apache.seatunnel.engine.server.CoordinatorService.submitJob(CoordinatorService.java:632) at org.apache.seatunnel.engine.server.operation.SubmitJobOperation.doRun(SubmitJobOperation.java:69) at org.apache.seatunnel.engine.server.operation.AsyncOperation.run(AsyncOperation.java:52) at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:411) at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:438) at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:601) at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:580) at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:61) at com.hazelcast.client.impl.protocol.task.AbstractInvocationMessageTask.processInternal(AbstractInvocationMessageTask.java:38) at com.hazelcast.client.impl.protocol.task.AbstractAsyncMessageTask.processMessage(AbstractAsyncMessageTask.java:71) at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.initializeAndProcessMessage(AbstractMessageTask.java:153) at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.run(AbstractMessageTask.java:116) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) Caused by: java.lang.RuntimeException: multi table sink can not write table: ffp at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:196) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:269) ... 132 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:218) ... 2 more [] 2026-01-15 08:55:29,484 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:226) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.example.engine.SeaTunnelEngineLocalExample.main(SeaTunnelEngineLocalExample.java:48) Caused by: org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: java.lang.RuntimeException: java.lang.RuntimeException: multi table sink can not write table: ffp at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:303) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:70) 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:82) at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.collect(IntermediateBlockingQueue.java:56) at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.collect(IntermediateQueueFlowLifeCycle.java:51) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.collect(TransformSeaTunnelTask.java:72) at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) at org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask.call(TransformSeaTunnelTask.java:77) at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:683) at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1012) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) at java.util.concurrent.FutureTask.run(FutureTask.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.FutureTask.<init>(FutureTask.java:151) at java.util.concurrent.AbstractExecutorService.newTaskFor(AbstractExecutorService.java:87) at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:111) at org.apache.seatunnel.api.tracing.MDCExecutorService.submit(MDCExecutorService.java:78) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) at org.apache.seatunnel.engine.server.TaskExecutionService.submitBlockingTask(TaskExecutionService.java:255) at org.apache.seatunnel.engine.server.TaskExecutionService.deployLocalTask(TaskExecutionService.java:405) at org.apache.seatunnel.engine.server.TaskExecutionService.deployTask(TaskExecutionService.java:340) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.lambda$deployOnLocal$0(PhysicalVertex.java:269) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.deployInternal(PhysicalVertex.java:324) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.deployOnLocal(PhysicalVertex.java:263) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.deploy(PhysicalVertex.java:311) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.stateProcess(PhysicalVertex.java:558) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.updateTaskState(PhysicalVertex.java:390) at org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex.makeTaskGroupDeploy(PhysicalVertex.java:304) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$stateProcess$21(SubPlan.java:673) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:669) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:655) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:624) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.startSubPlanStateProcess(SubPlan.java:608) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.restorePipeline(SubPlan.java:496) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:699) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$4(SubPlan.java:228) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.CompletableFuture$UniAccept.<init>(CompletableFuture.java:641) at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:684) at java.util.concurrent.CompletableFuture.thenAcceptAsync(CompletableFuture.java:2019) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.addPhysicalVertexCallBack(SubPlan.java:198) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$initStateFuture$3(SubPlan.java:189) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.initStateFuture(SubPlan.java:187) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.addPipelineEndCallback(PhysicalPlan.java:145) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.prepareRestorePipeline(SubPlan.java:472) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:696) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$4(SubPlan.java:228) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.CompletableFuture$UniAccept.<init>(CompletableFuture.java:641) at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:684) at java.util.concurrent.CompletableFuture.thenAcceptAsync(CompletableFuture.java:2019) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.addPhysicalVertexCallBack(SubPlan.java:198) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$initStateFuture$3(SubPlan.java:189) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.initStateFuture(SubPlan.java:187) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.addPipelineEndCallback(PhysicalPlan.java:145) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.prepareRestorePipeline(SubPlan.java:472) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.stateProcess(SubPlan.java:696) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.updatePipelineState(SubPlan.java:383) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$addPhysicalVertexCallBack$4(SubPlan.java:228) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) at java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:646) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.CompletableFuture$UniAccept.<init>(CompletableFuture.java:641) at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:684) at java.util.concurrent.CompletableFuture.thenAcceptAsync(CompletableFuture.java:2019) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.addPhysicalVertexCallBack(SubPlan.java:198) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.lambda$initStateFuture$3(SubPlan.java:189) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.SubPlan.initStateFuture(SubPlan.java:187) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.addPipelineEndCallback(PhysicalPlan.java:145) at java.util.ArrayList.forEach(ArrayList.java:1259) at org.apache.seatunnel.engine.server.dag.physical.PhysicalPlan.initStateFuture(PhysicalPlan.java:140) at org.apache.seatunnel.engine.server.master.JobMaster.initStateFuture(JobMaster.java:371) at org.apache.seatunnel.engine.server.master.JobMaster.init(JobMaster.java:305) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:646) at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) at java.util.concurrent.FutureTask.run(FutureTask.java) at --- Async.Stack.Trace --- (captured by IntelliJ IDEA debugger) at java.util.concurrent.FutureTask.<init>(FutureTask.java:151) at java.util.concurrent.AbstractExecutorService.newTaskFor(AbstractExecutorService.java:87) at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:111) at org.apache.seatunnel.api.tracing.MDCExecutorService.submit(MDCExecutorService.java:78) at org.apache.seatunnel.engine.server.CoordinatorService.submitJob(CoordinatorService.java:632) at org.apache.seatunnel.engine.server.operation.SubmitJobOperation.doRun(SubmitJobOperation.java:69) at org.apache.seatunnel.engine.server.operation.AsyncOperation.run(AsyncOperation.java:52) at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:411) at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:438) at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:601) at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:580) at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:61) at com.hazelcast.client.impl.protocol.task.AbstractInvocationMessageTask.processInternal(AbstractInvocationMessageTask.java:38) at com.hazelcast.client.impl.protocol.task.AbstractAsyncMessageTask.processMessage(AbstractAsyncMessageTask.java:71) at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.initializeAndProcessMessage(AbstractMessageTask.java:153) at com.hazelcast.client.impl.protocol.task.AbstractMessageTask.run(AbstractMessageTask.java:116) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) Caused by: java.lang.RuntimeException: multi table sink can not write table: ffp at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:196) at org.apache.seatunnel.api.sink.multitablesink.MultiTableSinkWriter.write(MultiTableSinkWriter.java:47) at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.received(SinkFlowLifeCycle.java:269) ... 132 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:218) ... 2 more ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version jdk 1.8 ### Screenshots _No response_ ### 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]
