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

   ### 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
   
   One of the column name of the oracle target table , is "LEVEL",which is a 
keyword of Oracle.
   When running the seatunnel job, it raise error : "ORA-00923: FROM keyword 
not found where expected" .
   And if the column "LEVEL" is excluded from the column list, it runs find.
   
   ### SeaTunnel Version
   
   2.3.3
   
   ### SeaTunnel Config
   
   ```conf
   env {
     # You can set engine configuration here
     execution.parallelism = 3
     job.mode = "STREAMING"
     execution.checkpoint.interval = 5000
   }
   
   source {
   
            MySQL-CDC {
                result_table_name = "source_financial_institution"
                # 数据库账号
                username = "sync"
                password = "***_cifi2020"
                table-names = ["cms_fund.financial_institution"]
                base-url = "jdbc:mysql://10.129.11.111:3306/cund"
                #catalog {
                # factory = MySQL
                # }
       }
   }
   
   transform {
           FieldMapper {
               source_table_name = "source_financial_institution"
               result_table_name = "trans_financial_institution"
               field_mapper = {
                   tenant_id                  = TENANT_ID
                   set_of_books_id            = SET_OF_BOOKS_ID
                   id                         = ID
                   financial_institution_id   = FINANCIAL_INSTITUTION_ID
                   financial_institution_code = FINANCIAL_INSTITUTION_CODE
                   financial_institution_name = FINANCIAL_INSTITUTION_NAME
                   organization_type          = ORGANIZATION_TYPE
                   remark                     = REMARK
                   enabled                    = ENABLED
                   deleted                    = DELETED
                   version_number             = VERSION_NUMBER
                   created_date               = CREATED_DATE
                   created_by                 = CREATED_BY
                   last_updated_date          = LAST_UPDATED_DATE
                   last_updated_by            = LAST_UPDATED_BY
                   level                      = LEVEL
       }
     }
   }
   
   sink {
           jdbc {
               url = "jdbc:oracle:thin:@10.121.11.111:1521:sdb"
               driver = "oracle.jdbc.OracleDriver"
               user = "ods"
               password = "ODS#***"
               generate_sink_sql = true
               source_table_name = "trans_financial_institution"
               # You need to configure both database and table
               database = "rodsdb"
               table = "ODS.CMS_FINANCIAL_INSTITUTION"
               primary_keys = ["ID"]
       }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   /app/seatunnel/bin/seatunnel.sh \
   --config /app/seatunnel/config/crc_mysql2oracle.conf \
   --name crc_mysql2oracle
   ```
   
   
   ### Error Exception
   
   ```log
   Caused by: java.sql.BatchUpdateException: ORA-00923: FROM keyword not found 
where expected
   
           at 
oracle.jdbc.driver.OraclePreparedStatement.executeLargeBatch(OraclePreparedStatement.java:9723)
           at 
oracle.jdbc.driver.T4CPreparedStatement.executeLargeBatch(T4CPreparedStatement.java:1447)
           at 
oracle.jdbc.driver.OraclePreparedStatement.executeBatch(OraclePreparedStatement.java:9499)
           at 
oracle.jdbc.driver.OracleStatementWrapper.executeBatch(OracleStatementWrapper.java:237)
           at 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:533)
           at 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:51)
           at 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:89)
           at 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:165)
           at 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:130)
           ... 19 more
   
           at 
org.apache.seatunnel.engine.client.job.ClientJobProxy.waitForJobComplete(ClientJobProxy.java:122)
           at 
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:184)
           ... 2 more
   2024-03-01 15:07:08,139 INFO  
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - run 
shutdown hook because get close signal
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   zeta
   
   ### Java or Scala Version
   
   java 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]

Reply via email to