MossMole opened a new issue, #8232: URL: https://github.com/apache/seatunnel/issues/8232
### 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 When I use seatunnel to migrate Dameng database table data to MySQL database, the background prompts that some database table fields of Dameng are not supported. The common feature of these fields is that they are all of nvarchar2 type. ### SeaTunnel Version `3.2.2` ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "BATCH" } source { Jdbc { url = "jdbc:dm://192.168.2.93:5236?key1=val1..." driver = "dm.jdbc.driver.DmDriver" user = "xxx" password = "xxx" connection_check_timeout_sec = 100 table_list = [ {table_path = "PROPERTIES.ACT_EVT_LOG"}, ...略 ] } } sink { Jdbc { url = "jdbc:mysql://192.168.2.93:3306" driver = "com.mysql.cj.jdbc.Driver" user = "yyy" password = "yyy" generate_sink_sql = true database = "properties" table_list = [ properties.act_evt_log, ...略 ] } } ``` ### Running Command ```shell 在dolphinscheduler中调用，local模式运行 ``` ### Error Exception ```log =============================================================================== 2024-12-07 07:49:24,582 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2024-12-07 07:49:24,582 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-12-07 07:49:24,582 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2024-12-07 07:49:24,584 ERROR [o.a.s.c.s.SeaTunnel ] [main] - 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 'Jdbc'. 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.exception.SeaTunnelRuntimeException: ErrorCode:[COMMON-21], ErrorDescription:['Dameng' tables unsupported get catalog table，the corresponding field types in the following tables are not supported: '{"PROPERTIES.ACT_EVT_LOG":{"TYPE_":"NVARCHAR2","PROC_DEF_ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","EXECUTION_ID_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","USER_ID_":"NVARCHAR2","LOCK_OWNER_":"NVARCHAR2"},"PROPERTIES.ACT_GE_BYTEARRAY":{"ID_":"NVARCHAR2","NAME_":"NVARCHAR2","DEPLOYMENT_ID_":"NVARCHAR2"},"PROPERTIES.ACT_GE_PROPERTY":{"NAME_":"NVARCHAR2","VALUE_":"NVARCHAR2"},"PROPERTIES.ACT_HI_ACTINST":{"ID_":"NVARCHAR2","PROC_DEF_ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","EXECUTION_ID_":"NVARCHAR2","ACT_ID_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","CALL_PROC_INST_ID_":"NVARCHAR2","ACT_NAME_":"NVARCHAR2","ACT_TYPE_":"NVARCHAR2","ASSIGNEE_":"NVARCHAR2","DELETE_REASON_":"NVARCHAR2","TENANT_ID_":"NVARCHAR2"},"PROPERTIES.ACT_HI_ATTACHMENT":{"ID_":"NVARCHA R2","USER_ID_":"NVARCHAR2","NAME_":"NVARCHAR2","DESCRIPTION_":"NVARCHAR2","TYPE_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","URL_":"NVARCHAR2","CONTENT_ID_":"NVARCHAR2"},"PROPERTIES.ACT_HI_COMMENT":{"ID_":"NVARCHAR2","TYPE_":"NVARCHAR2","USER_ID_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","ACTION_":"NVARCHAR2","MESSAGE_":"NVARCHAR2"},"PROPERTIES.ACT_HI_DETAIL":{"ID_":"NVARCHAR2","TYPE_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","EXECUTION_ID_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","ACT_INST_ID_":"NVARCHAR2","NAME_":"NVARCHAR2","VAR_TYPE_":"NVARCHAR2","BYTEARRAY_ID_":"NVARCHAR2","TEXT_":"NVARCHAR2","TEXT2_":"NVARCHAR2"},"PROPERTIES.ACT_HI_ENTITYLINK":{"ID_":"NVARCHAR2","LINK_TYPE_":"NVARCHAR2","SCOPE_ID_":"NVARCHAR2","SUB_SCOPE_ID_":"NVARCHAR2","SCOPE_TYPE_":"NVARCHAR2","SCOPE_DEFINITION_ID_":"NVARCHAR2","PARENT_ELEMENT_ID_":"NVARCHAR2","REF_SCOPE_ID_":"NVARCHAR2","REF_SCOPE_TYPE_":"NVARCHAR2","REF_SCOPE_DEFINITION_ID_":"NVARCHAR2","ROOT_SCOPE_ID_ ":"NVARCHAR2","ROOT_SCOPE_TYPE_":"NVARCHAR2","HIERARCHY_TYPE_":"NVARCHAR2"},"PROPERTIES.ACT_HI_IDENTITYLINK":{"ID_":"NVARCHAR2","GROUP_ID_":"NVARCHAR2","TYPE_":"NVARCHAR2","USER_ID_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","SCOPE_ID_":"NVARCHAR2","SUB_SCOPE_ID_":"NVARCHAR2","SCOPE_TYPE_":"NVARCHAR2","SCOPE_DEFINITION_ID_":"NVARCHAR2"},"PROPERTIES.ACT_HI_PROCINST":{"ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","BUSINESS_KEY_":"NVARCHAR2","PROC_DEF_ID_":"NVARCHAR2","START_USER_ID_":"NVARCHAR2","START_ACT_ID_":"NVARCHAR2","END_ACT_ID_":"NVARCHAR2","SUPER_PROCESS_INSTANCE_ID_":"NVARCHAR2","DELETE_REASON_":"NVARCHAR2","TENANT_ID_":"NVARCHAR2","NAME_":"NVARCHAR2","CALLBACK_ID_":"NVARCHAR2","CALLBACK_TYPE_":"NVARCHAR2","REFERENCE_ID_":"NVARCHAR2","REFERENCE_TYPE_":"NVARCHAR2","PROPAGATED_STAGE_INST_ID_":"NVARCHAR2","BUSINESS_STATUS_":"NVARCHAR2"},"PROPERTIES.ACT_HI_TASKINST":{"ID_":"NVARCHAR2","PROC_DEF_ID_":"NVARCHAR2","TASK_DEF_ID_":"NVARCHAR2","TASK_DEF_KEY_":"NVA RCHAR2","PROC_INST_ID_":"NVARCHAR2","EXECUTION_ID_":"NVARCHAR2","SCOPE_ID_":"NVARCHAR2","SUB_SCOPE_ID_":"NVARCHAR2","SCOPE_TYPE_":"NVARCHAR2","SCOPE_DEFINITION_ID_":"NVARCHAR2","PROPAGATED_STAGE_INST_ID_":"NVARCHAR2","PARENT_TASK_ID_":"NVARCHAR2","NAME_":"NVARCHAR2","DESCRIPTION_":"NVARCHAR2","OWNER_":"NVARCHAR2","ASSIGNEE_":"NVARCHAR2","DELETE_REASON_":"NVARCHAR2","FORM_KEY_":"NVARCHAR2","CATEGORY_":"NVARCHAR2","TENANT_ID_":"NVARCHAR2"},"PROPERTIES.ACT_HI_TSK_LOG":{"TYPE_":"NVARCHAR2","TASK_ID_":"NVARCHAR2","USER_ID_":"NVARCHAR2","DATA_":"NVARCHAR2","EXECUTION_ID_":"NVARCHAR2","PROC_INST_ID_":"NVARCHAR2","PROC_DEF_ID_":"NVARCHAR2","SCOPE_ID_":"NVARCHAR2","SCOPE_DEFINITION_ID_":"NVARCHAR2","SUB_SCOPE_ID_":"NVARCHAR2","SCOPE_TYPE_":"NVARCHAR2","TENANT_ID_":"NVARCHAR2"},"PROPERTIES.FLW_RU_BATCH":{"ID_":"NVARCHAR2","TYPE_":"NVARCHAR2","SEARCH_KEY_":"NVARCHAR2","SEARCH_KEY2_":"NVARCHAR2","STATUS_":"NVARCHAR2","BATCH_DOC_ID_":"NVARCHAR2","TENANT_ID_":"NVARCHAR2"},"PROPERTIES.FLW_RU_BATCH _PART":{"ID_":"NVARCHAR2","BATCH_ID_":"NVARCHAR2","TYPE_":"NVARCHAR2","SCOPE_ID_":"NVARCHAR2","SUB_SCOPE_ID_":"NVARCHAR2","SCOPE_TYPE_":"NVARCHAR2","SEARCH_KEY_":"NVARCHAR2","SEARCH_KEY2_":"NVARCHAR2","STATUS_":"NVARCHAR2","RESULT_DOC_ID_":"NVARCHAR2","TENANT_ID_":"NVARCHAR2"}}'] at org.apache.seatunnel.common.exception.CommonError.getCatalogTablesWithUnsupportedType(CommonError.java:188) at org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils.getTables(JdbcCatalogUtils.java:115) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.<init>(JdbcSource.java:57) at org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceFactory.lambda$createSource$0(JdbcSourceFactory.java:80) 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 2024-12-07 07:49:24,584 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version `JDK 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: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
