inuexx opened a new issue, #9077:
URL: https://github.com/apache/seatunnel/issues/9077

   ### 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
   
   要求两表实时同步,启动时总是报错: Unable to create a source for identifier 'Oracle-CDC'
   oracle 版本 11g
   connector-cdc-oracle-2.3.6.jar
   ojdbc8-21.9.0.0.jar
   文件都在 lib 目录内
   
   ### SeaTunnel Version
   
   apache-seatunnel-2.3.6
   
   ### SeaTunnel Config
   
   ```conf
   env {
     execution.parallelism = 1
     job.mode = "STREAMING"
   }
   
   source {
     Oracle-CDC {
       # 必须配置项
       username = "test"
       password = "test"
       database-name = "orcl"
       schema-name = "TEST"
       table-name = "LOG_1"
   
       # 连接配置
       url = "jdbc:oracle:thin:@//localhost:1521/orcl"
       driver-class-name = "oracle.jdbc.OracleDriver"
   
       # 重要Debezium参数
       debezium {
         # 基础参数
         database.server.name = "oracle_server"
         database.history.skip.unparseable.ddl = true
         # "initial" 或 "schema_only"
         snapshot.mode = "initial"
   
         # 日志挖掘策略
         log.mining.strategy = "online_catalog"
         log.mining.continuous.mine = true
   
         # Oracle 11g 特殊参数
         database.tablename.case.insensitive = true
         log.mining.archive.log.only = true
   
         # 时区配置(重要)
         database.connection.timezone = "Asia/Shanghai"
         database.serverTimezone = "Asia/Shanghai"
   
         # 缓冲区配置
         log.mining.buffer.size = 40960
         log.mining.buffer.type = "memory"
   
         # 批量处理
         log.mining.batch.size.min = 100
         log.mining.batch.size.max = 1000
   
         # 心跳配置
         heartbeat.interval.ms = 60000
       }
     }
   }
   
   sink {
     Jdbc {
       url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl"
       driver = "oracle.jdbc.OracleDriver"
       user = "test"
       password = "test"
       table = "LOG_2"
       primary_keys = ["ID"]
   
       # 启用upsert模式
       support_upsert_by_query = true
       upsert_key = ["ID"]
   
       # 批量提交提高性能
       batch_size = 1000
       batch_interval_ms = 1000
     }
   }
   ```
   
   ### Running Command
   
   ```shell
   chcp 936
   .\bin\seatunnel.cmd -c .\conf\cdc_oracle.conf -m local
   ```
   
   ### Error Exception
   
   ```log
   2025-03-28 16:13:34,685 ERROR org.apache.seatunnel.core.starter.SeaTunnel -
   
   
===============================================================================
   
   
   2025-03-28 16:13:34,686 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Fatal Error,
   
   2025-03-28 16:13:34,686 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Please submit bug report in https://github.com/apache/seatunnel/issues
   
   2025-03-28 16:13:34,687 ERROR org.apache.seatunnel.core.starter.SeaTunnel - 
Reason:SeaTunnel job executed failed
   
   2025-03-28 16:13:34,689 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:211)
           at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
           at 
org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)
   Caused by: org.apache.seatunnel.api.table.factory.FactoryException: 
ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to 
create a source for identifier 'Oracle-CDC'.
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:101)
           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.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:158)
           ... 2 more
   Caused by: org.apache.seatunnel.common.utils.SeaTunnelException: Can not 
find catalog table with factoryId [Oracle]
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.lambda$getCatalogTables$0(CatalogTableUtil.java:131)
           at java.util.Optional.map(Unknown Source)
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:118)
           at 
org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTables(CatalogTableUtil.java:98)
           at 
org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.OracleIncrementalSourceFactory.lambda$createSource$1(OracleIncrementalSourceFactory.java:108)
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:113)
           at 
org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSource(FactoryUtil.java:74)
           ... 7 more
   ```
   
   ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to