304792747 opened a new issue, #9392: URL: https://github.com/apache/seatunnel/issues/9392
### 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 使用 TableRename转换模块，重命名表名，不生效。 ### SeaTunnel Version 2.3.11 ### SeaTunnel Config ```conf // API JSON BODY { "env": { "job.mode": "batch" }, "source": [ { "plugin_output": "tt1", "plugin_name": "Jdbc", // 数据库访问插件 "url": "jdbc:oracle:thin:@192.168.2.26:1521:spring", // 数据库地址、端口、实例 "driver": "oracle.jdbc.OracleDriver", // 数据库驱动 "user": "xx", // 用户名 "password": "xx", // 密码 "query": "select * from d_department" // sql语句 } ], "transform": [ { "plugin_input": [ "tt1" ], "plugin_output": "tt2", "prefix": "CDC_", "suffix": "", "replacements_with_regex": [ { "replace_from": "", "replace_to": "" } ], "plugin_name": "TableRename" } ], "sink": [ { "plugin_input": [ "tt2" ], "plugin_name": "Jdbc", // 数据库访问插件 "url": "jdbc:oracle:thin:@192.168.2.13:1521:orcl", // 数据库地址、端口、实例 "driver": "oracle.jdbc.OracleDriver", // 数据库驱动 "user": "xx", // 用户名 "password": "xx", // 密码 "generate_sink_sql": true, // 根据要写入的数据库表生成sql语句。必填 "database": "orcl", // 接收数据库实例名。必填 "table": "AAAA", // 接收数据表名 "schema_save_mode": "RECREATE_SCHEMA" } ] } ``` ### Running Command ```shell nohup sh bin/seatunnel-cluster.sh 2>&1 & ``` ### Error Exception ```log [] 2025-06-03 14:52:02,380 INFO [o.a.s.c.s.u.ConfigBuilder ] [qtp1407675409-110] - Parsed config file: { "env" : { "job.mode" : "batch" }, "source" : [ { "plugin_output" : "tt1", "plugin_name" : "Jdbc", "url" : "jdbc:oracle:thin:@192.168.2.26:1521:spring", "driver" : "oracle.jdbc.OracleDriver", "user" : "bos", "password" : "******", "query" : "select * from d_department" } ], "transform" : [ { "plugin_input" : [ "tt1" ], "plugin_output" : "tt2", "prefix" : "CDC_", "suffix" : "", "replacements_with_regex" : [ { "replace_from" : "", "replace_to" : "" } ], "plugin_name" : "TableRename" } ], "sink" : [ { "plugin_input" : [ "tt2" ], "plugin_name" : "Jdbc", "url" : "jdbc:oracle:thin:@192.168.2.13:1521:orcl", "driver" : "oracle.jdbc.OracleDriver", "user" : "ods_bmis", "password" : "******", "generate_sink_sql" : true, "database" : "orcl", "table" : "AAAA", "schema_save_mode" : "RECREATE_SCHEMA" } ] } [] 2025-06-03 14:52:02,381 INFO [p.MultipleTableJobConfigParser] [qtp1407675409-110] - add common jar in plugins :[] [] 2025-06-03 14:52:02,386 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Load SeaTunnelSink Plugin from /usr/apache/apache-seatunnel-2.3.11/connectors [] 2025-06-03 14:52:02,386 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} at: file:/usr/apache/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar [] 2025-06-03 14:52:02,392 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Load SeaTunnelSink Plugin from /usr/apache/apache-seatunnel-2.3.11/connectors [] 2025-06-03 14:52:02,392 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='transform', pluginName='TableRename'} at: file:/usr/apache/apache-seatunnel-2.3.11/connectors/seatunnel-transforms-v2-2.3.11.jar [] 2025-06-03 14:52:02,397 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Load SeaTunnelSink Plugin from /usr/apache/apache-seatunnel-2.3.11/connectors [] 2025-06-03 14:52:02,397 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Jdbc'} at: file:/usr/apache/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar [] 2025-06-03 14:52:02,399 INFO [p.MultipleTableJobConfigParser] [qtp1407675409-110] - start generating all sources. [] 2025-06-03 14:52:02,417 INFO [o.a.s.c.s.j.u.JdbcCatalogUtils] [qtp1407675409-110] - Loading catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.oracle.OracleCatalog [] 2025-06-03 14:52:28,993 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [qtp1407675409-110] - Catalog Oracle established connection to jdbc:oracle:thin:@192.168.2.26:1521:spring [] 2025-06-03 14:52:28,996 INFO [o.a.s.c.s.j.u.JdbcCatalogUtils] [qtp1407675409-110] - Loaded 1 catalog tables for catalog : class org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.oracle.OracleCatalog [] 2025-06-03 14:52:28,999 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [qtp1407675409-110] - Catalog Oracle closing [] 2025-06-03 14:52:28,999 INFO [o.a.s.a.t.f.FactoryUtil ] [qtp1407675409-110] - get the CatalogTable from source Jdbc: jdbc_catalog.default.default.default [] 2025-06-03 14:52:29,000 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Load SeaTunnelSource Plugin from /usr/apache/apache-seatunnel-2.3.11/connectors [] 2025-06-03 14:52:29,001 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='Jdbc'} at: file:/usr/apache/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar [] 2025-06-03 14:52:29,001 INFO [p.MultipleTableJobConfigParser] [qtp1407675409-110] - start generating all transforms. [] 2025-06-03 14:52:29,007 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Load SeaTunnelTransform Plugin from /usr/apache/apache-seatunnel-2.3.11/connectors [] 2025-06-03 14:52:29,009 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='transform', pluginName='TableRename'} at: file:/usr/apache/apache-seatunnel-2.3.11/connectors/seatunnel-transforms-v2-2.3.11.jar [] 2025-06-03 14:52:29,016 INFO [p.MultipleTableJobConfigParser] [qtp1407675409-110] - start generating all sinks. [] 2025-06-03 14:52:29,022 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Load SeaTunnelSink Plugin from /usr/apache/apache-seatunnel-2.3.11/connectors [] 2025-06-03 14:52:29,023 INFO [.s.p.d.AbstractPluginDiscovery] [qtp1407675409-110] - Discovery plugin jar for: PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='Jdbc'} at: file:/usr/apache/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar [] 2025-06-03 14:52:29,039 INFO [o.a.s.a.t.f.FactoryUtil ] [qtp1407675409-110] - Create sink 'Jdbc' with upstream input catalog-table[database: default, schema: default, table: CDC_default] [982174473505538049] 2025-06-03 14:52:29,046 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-8] - in batch mode, the 'checkpoint.interval' configuration of env is missing, so checkpoint will be disabled [982174473505538049] 2025-06-03 14:52:29,047 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-8] - Init JobMaster for Job SeaTunnel_Job (982174473505538049) [982174473505538049] 2025-06-03 14:52:29,047 INFO [o.a.s.e.s.m.JobMaster ] [seatunnel-coordinator-service-8] - Job SeaTunnel_Job (982174473505538049) needed jar urls [file:/usr/apache/apache-seatunnel-2.3.11/connectors/connector-jdbc-2.3.11.jar, file:/usr/apache/apache-seatunnel-2.3.11/connectors/seatunnel-transforms-v2-2.3.11.jar] [982174473505538049] 2025-06-03 14:52:29,116 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-8] - Catalog Oracle established connection to jdbc:oracle:thin:@192.168.2.13:1521:orcl [982174473505538049] 2025-06-03 14:52:29,116 INFO [a.s.a.s.SaveModeExecuteWrapper] [seatunnel-coordinator-service-8] - Executing save mode for table: orcl.AAAA, with SchemaSaveMode: RECREATE_SCHEMA, DataSaveMode: APPEND_DATA using Catalog: Oracle [982174473505538049] 2025-06-03 14:52:29,119 INFO [a.s.a.s.DefaultSaveModeHandler] [seatunnel-coordinator-service-8] - Creating table orcl.AAAA with action CREATE TABLE "AAAA" ( "ID" INTEGER NOT NULL, "CUSTOMID" VARCHAR2(40), "NAME" VARCHAR2(120) NOT NULL, "PRONUNCIATION" VARCHAR2(60), "UIORDER" INTEGER, "BRANCH" VARCHAR2(8) NOT NULL, "AVAILABLE" NUMBER(1) NOT NULL, "PARENTID" INTEGER ) [982174473505538049] 2025-06-03 14:52:29,121 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-8] - Execute sql : CREATE TABLE "AAAA" ( "ID" INTEGER NOT NULL, "CUSTOMID" VARCHAR2(40), "NAME" VARCHAR2(120) NOT NULL, "PRONUNCIATION" VARCHAR2(60), "UIORDER" INTEGER, "BRANCH" VARCHAR2(8) NOT NULL, "AVAILABLE" NUMBER(1) NOT NULL, "PARENTID" INTEGER ) [982174473505538049] 2025-06-03 14:52:29,133 INFO [.s.c.s.j.c.AbstractJdbcCatalog] [seatunnel-coordinator-service-8] - Catalog Oracle closing [982174473505538049] 2025-06-03 14:52:29,134 ERROR [o.a.s.e.s.CoordinatorService ] [seatunnel-coordinator-service-8] - [localhost]:5801 [seatunnel] [5.1] submit job 982174473505538049 error org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[API-09], ErrorDescription:[Handle save mode failed] at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:568) at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:574) at org.apache.seatunnel.engine.server.master.JobMaster.lambda$init$1(JobMaster.java:273) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.Iterator.forEachRemaining(Iterator.java:116) at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.apache.seatunnel.engine.server.master.JobMaster.init(JobMaster.java:267) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:649) 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(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed creating table orcl.AAAA at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTableInternal(AbstractJdbcCatalog.java:438) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTable(AbstractJdbcCatalog.java:414) at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.savemode.JdbcSaveModeHandler.createTable(JdbcSaveModeHandler.java:48) at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.recreateSchema(DefaultSaveModeHandler.java:124) at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.handleSchemaSaveMode(DefaultSaveModeHandler.java:85) at org.apache.seatunnel.api.sink.SaveModeHandler.handleSaveMode(SaveModeHandler.java:40) at org.apache.seatunnel.api.sink.SaveModeExecuteWrapper.execute(SaveModeExecuteWrapper.java:36) at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:566) ... 21 more Caused by: java.sql.SQLSyntaxErrorException: ORA-00955: 名称已由现有对象使用 at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:447) at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:396) at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:951) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:513) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:227) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:531) at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:208) at oracle.jdbc.driver.T4CPreparedStatement.executeForRows(T4CPreparedStatement.java:1046) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1336) at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3613) at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3714) at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1378) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.executeInternal(AbstractJdbcCatalog.java:609) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTableInternal(AbstractJdbcCatalog.java:434) ... 28 more [] 2025-06-03 14:52:29,136 ERROR [.s.r.f.ExceptionHandlingFilter] [qtp1407675409-110] - Error occurred while processing request java.util.concurrent.CompletionException: org.apache.seatunnel.engine.common.exception.JobException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[API-09], ErrorDescription:[Handle save mode failed] at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:568) at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:574) at org.apache.seatunnel.engine.server.master.JobMaster.lambda$init$1(JobMaster.java:273) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.Iterator.forEachRemaining(Iterator.java:116) at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.apache.seatunnel.engine.server.master.JobMaster.init(JobMaster.java:267) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:649) 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(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed creating table orcl.AAAA at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTableInternal(AbstractJdbcCatalog.java:438) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTable(AbstractJdbcCatalog.java:414) at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.savemode.JdbcSaveModeHandler.createTable(JdbcSaveModeHandler.java:48) at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.recreateSchema(DefaultSaveModeHandler.java:124) at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.handleSchemaSaveMode(DefaultSaveModeHandler.java:85) at org.apache.seatunnel.api.sink.SaveModeHandler.handleSaveMode(SaveModeHandler.java:40) at org.apache.seatunnel.api.sink.SaveModeExecuteWrapper.execute(SaveModeExecuteWrapper.java:36) at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:566) ... 21 more Caused by: java.sql.SQLSyntaxErrorException: ORA-00955: 名称已由现有对象使用 at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:447) at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:396) at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:951) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:513) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:227) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:531) at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:208) at oracle.jdbc.driver.T4CPreparedStatement.executeForRows(T4CPreparedStatement.java:1046) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1336) at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3613) at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3714) at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1378) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.executeInternal(AbstractJdbcCatalog.java:609) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTableInternal(AbstractJdbcCatalog.java:434) ... 28 more at java.util.concurrent.CompletableFuture.reportJoin(CompletableFuture.java:375) ~[?:1.8.0_412] at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1947) ~[?:1.8.0_412] at org.apache.seatunnel.engine.common.utils.concurrent.CompletableFuture.join(CompletableFuture.java:156) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.rest.service.BaseService.submitJob(BaseService.java:533) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.rest.service.BaseService.submitJobInternal(BaseService.java:513) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.rest.service.JobInfoService.submitJob(JobInfoService.java:173) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.rest.servlet.SubmitJobServlet.doPost(SubmitJobServlet.java:48) ~[seatunnel-starter.jar:2.3.10] at javax.servlet.http.HttpServlet.service(HttpServlet.java:707) ~[connector-cdc-mongodb-2.3.10.jar:2.3.10] at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[connector-cdc-mongodb-2.3.10.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1656) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.engine.server.rest.filter.ExceptionHandlingFilter.doFilter(ExceptionHandlingFilter.java:50) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:552) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.Server.handle(Server.java:516) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) ~[seatunnel-starter.jar:2.3.10] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_412] Caused by: org.apache.seatunnel.engine.common.exception.JobException: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[API-09], ErrorDescription:[Handle save mode failed] at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:568) at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:574) at org.apache.seatunnel.engine.server.master.JobMaster.lambda$init$1(JobMaster.java:273) at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at java.util.Iterator.forEachRemaining(Iterator.java:116) at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485) at org.apache.seatunnel.engine.server.master.JobMaster.init(JobMaster.java:267) at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:649) 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(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: org.apache.seatunnel.api.table.catalog.exception.CatalogException: ErrorCode:[API-03], ErrorDescription:[Catalog initialize failed] - Failed creating table orcl.AAAA at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTableInternal(AbstractJdbcCatalog.java:438) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTable(AbstractJdbcCatalog.java:414) at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.savemode.JdbcSaveModeHandler.createTable(JdbcSaveModeHandler.java:48) at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.recreateSchema(DefaultSaveModeHandler.java:124) at org.apache.seatunnel.api.sink.DefaultSaveModeHandler.handleSchemaSaveMode(DefaultSaveModeHandler.java:85) at org.apache.seatunnel.api.sink.SaveModeHandler.handleSaveMode(SaveModeHandler.java:40) at org.apache.seatunnel.api.sink.SaveModeExecuteWrapper.execute(SaveModeExecuteWrapper.java:36) at org.apache.seatunnel.engine.server.master.JobMaster.handleSaveMode(JobMaster.java:566) ... 21 more Caused by: java.sql.SQLSyntaxErrorException: ORA-00955: 名称已由现有对象使用 at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:447) at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:396) at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:951) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:513) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:227) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:531) at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:208) at oracle.jdbc.driver.T4CPreparedStatement.executeForRows(T4CPreparedStatement.java:1046) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1336) at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3613) at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3714) at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1378) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.executeInternal(AbstractJdbcCatalog.java:609) at org.apache.seatunnel.connectors.seatunnel.jdbc.catalog.AbstractJdbcCatalog.createTableInternal(AbstractJdbcCatalog.java:434) ... 28 more at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:656) ~[seatunnel-starter.jar:2.3.10] at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) ~[seatunnel-starter.jar:2.3.10] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_412] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_412] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_412] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_412] ... 1 more [] 2025-06-03 14:52:44,459 INFO [o.a.s.e.s.CoordinatorService ] [pool-7-thread-1] - [localhost]:5801 [seatunnel] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 1 corePoolSize : 10 maximumPoolSize : 2147483647 poolSize : 10 completedTaskCount : 56 taskCount : 57 *********************************************** ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### 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]
