apache/seatunnel

[Bug] [connector-jdbc] DM compatible data type NVARCHAR2

Open

#10.635 aperta il 21 mar 2026

Vedi su GitHub
 (5 commenti) (0 reazioni) (0 assegnatari)Java (1432 fork)batch import
buggood first issuehelp wanted

Metriche repository

Star
 (6897 star)
Metriche merge PR
 (Merge medio 13g 21h) (143 PR mergiate in 30 g)

Descrizione

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

When synchronizing multi-table data from Dameng Database to MySQL Database via the JDBC connector, the Source does not support NVARCHAR2 type mapping.

The task configuration is as follows:

{
  "env": {
    "parallelism": 1,
    "job.mode": "BATCH"
  },
  "source": [
    {
      "plugin_name": "Jdbc",
      "plugin_input": "source",
      "driver": "dm.jdbc.driver.DmDriver",
      "url": "jdbc:dm://1127.0.0.1:5236/sfsjzt",
      "user": "SYSDBA",
      "password": "SYSDBA001",
      "table_list": [
        {
          "table_path": "sfsjzt.test_nvarchar2"
        }
      ],
      "connection_check_timeout_sec": 100
    }
  ],
  "sink": [
    {
      "plugin_name": "Jdbc",
      "plugin_input": "sink",
      "url": "jdbc:mysql://127.0.0.1:3306/test?useSSL=false&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true", 
      "driver": "com.mysql.cj.jdbc.Driver",
      "user": "root",
      "password": "testing", 
      "generate_sink_sql": true,
      "database": "test",
      "table": "${table_name}",
      "data_save_mode": "append_data",
      "schema_save_mode": "CREATE_SCHEMA_WHEN_NOT_EXIST",
      "connection_check_timeout_sec": 100,
      "batch_size": 1000
    }
  ]
}

SeaTunnel Version

apache-seatunnel-2.3.8

SeaTunnel Config

Standalone testing environment

Running Command

../bin/seatunnel.sh --config dm_all_table_collect.json -m local

Error Exception

The error message is as follows
Caused by: org.apache.seatunnel.common.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-21], ErrorDescription:['Dameng' tables unsupported get catalog table,the corresponding field types in the following tables are not supported: '{"test.test_nvarchar2":{"id":"nvarchar2","name":"nvarchar2","age":"nvarchar2"}}'

Zeta or Flink or Spark Version

2.3.8

Java or Scala Version

jdk1.8

Screenshots

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Guida contributor