apache/seatunnel

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

Open

#10,635 opened on Mar 21, 2026

View on GitHub
 (5 comments) (0 reactions) (0 assignees)Java (1,432 forks)batch import
buggood first issuehelp wanted

Repository metrics

Stars
 (6,897 stars)
PR merge metrics
 (Avg merge 13d 21h) (143 merged PRs in 30d)

Description

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

Contributor guide