Skip to content

Unsupported multi table sink api, rollback to sink template #10408

@Alan-pan

Description

@Alan-pan

Search before asking

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

What happened

I previously used version 2.3.3 of SeaTunnel, and now I've upgraded to version 2.3.12, scheduling it through DolphinScheduler. However, I'm encountering failures with an error related to Hazelcast serialization. I haven't made any changes to my configuration except for updating the userparameter to usernamein the source section, and I'm using the new connector packages. The old version executes successfully, but the new version still fails.

SeaTunnel Version

2.3.12

SeaTunnel Config

mysql-connector-java-8.0.21.jar
connector-doris-2.3.12.jar
connector-jdbc-2.3.12.jar
connector-selectdb-cloud-2.3.12.jar

Running Command

2026-01-28 16:01:18,844 INFO  [o.a.s.c.s.u.ConfigBuilder     ] [main] - Parsed config file: 
	{
	    "env" : {
	        "execution.parallelism" : 2,
	        "job.mode" : "BATCH"
	    },
	    "source" : [
	        {
	            "url" : "jdbc:mysql://rm-uf6275fste3bk3ubp.mysql.rds.aliyuncs.com:3306/aws_prod?serverTimezone=GMT%2b8",
	            "driver" : "com.mysql.cj.jdbc.Driver",
	            "connection_check_timeout_sec" : 100,
	            "username" : "******",
	            "password" : "******",
	            "query" : "SELECT `ID` as id, `ORGID` as orgid, `BINDID` as bindid, `CREATEDATE` as createdate, `CREATEUSER` as createuser, `UPDATEDATE` as updatedate, `UPDATEUSER` as updateuser, `PROCESSDEFID` as processdefid, `ISEND` as isend, `BANK` as bank, `BANK_ACCOUNT` as bank_account, `ALIPAY_ACCOUNT` as alipay_account, `MEDIA_BUSINESSLINE` as media_businessline, `MEDIA_PRODUCT` as media_product, `RESOURCE_TRACK` as resource_track, `TRACK_DETAIL` as track_detail, `BELONG_SUBJECT_NAME` as belong_subject_name, `MEDIA_ACCOUNT` as media_account, `MEDIA_PASSWORD` as media_password, `STATUS` as status, `MEDIA_ACCOUNT_REAL` as media_account_real, `MEDIA_PASSWORD_REAL` as media_password_real, `BELONG_SUBJECT_ID` as belong_subject_id FROM `bo_eu_supplier_account`",
	            "partition_column" : "id",
	            "partition_num" : 2,
	            "plugin_name" : "Jdbc"
	        }
	    ],
	    "sink" : [
	        {
	            "load-url" : "selectdb-cn-9cw4lrs3v01.selectdbfe.rds.aliyuncs.com:8080",
	            "jdbc-url" : "selectdb-cn-9cw4lrs3v01.selectdbfe.rds.aliyuncs.com:9030",
	            "username" : "******",
	            "password" : "******",
	            "cluster-name" : "new_cluster",
	            "table.identifier" : "dw_precision_marketing.ods_zd_bo_eu_supplier_account",
	            "sink.enable-2pc" : "true",
	            "sink.enable-delete" : "true",
	            "selectdb.config" : {
	                "file.type" : "json"
	            },
	            "plugin_name" : "SelectDBCloud"
	        }
	    ]
	}

Error Exception

Caused by: java.io.NotSerializableException: org.apache.seatunnel.connectors.selectdb.config.SelectDBConfig

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

1769588613461.log

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions