[Bug] [Module Name] Postgresql->Postgresql error

[lemboyy]

Search before asking

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

What happened

A protocol error occurred when data was synchronized from the postgresql library to the postgresql library, and Session initialization failed.

SeaTunnel Version

2.3.8

SeaTunnel Config

{
    "transform" : [],
    "sink" : [
        {
            "batch_size" : "1000",
            "max_retries" : "0",
            "create_index" : "true",
            "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST",
            "source_table_name" : "Table15525536935648",
            "max_commit_attempts" : "3",
            "auto_commit" : "true",
            "plugin_name" : "Jdbc",
            "url" : "jdbc:postgresql://10.3.9.219:15432/seatunnel?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&currentSchema=public",
            "is_exactly_once" : "false",
            "database" : "seatunnel",
            "password" : "******",
            "transaction_timeout_sec" : "-1",
            "driver" : "org.postgresql.Driver",
            "data_save_mode" : "APPEND_DATA",
            "support_upsert_by_query_primary_key_exist" : "false",
            "connection_check_timeout_sec" : "30",
            "multi_table_sink_replica" : "1",
            "generate_sink_sql" : true,
            "user" : "postgres",
            "table" : "public.customer_copy1"
        }
    ],
    "source" : [
        {
            "split.inverse-sampling.rate" : "1000",
            "parallelism" : "1",
            "query" : "SELECT \"id\", \"name\", \"age\", \"phone\" FROM \"seatunnel\".\"public\".\"customer\"",
            "result_table_name" : "Table15525536935648",
            "split.even-distribution.factor.lower-bound" : "0.05",
            "plugin_name" : "Jdbc",
            "use_select_count" : "false",
            "url" : "jdbc:postgresql://10.3.9.219:15432/seatunnel?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai&currentSchema=public",
            "skip_analyze" : "false",
            "password" : "******",
            "driver" : "org.postgresql.Driver",
            "split.even-distribution.factor.upper-bound" : "100.0",
            "split.sample-sharding.threshold" : "1000",
            "connection_check_timeout_sec" : "30",
            "fetch_size" : "10",
            "user" : "postgres",
            "split.size" : "8096"
        }
    ],
    "env" : {
        "job.mode" : "BATCH",
        "job.name" : "SeaTunnel_Job",
        "savemode.execute.location" : "CLUSTER"
    }
}

Running Command

seatunnel web job run

Error Exception

org.apache.seatunnel.shade.org.postgresql.util.PSQLException: 通讯协定错误，Session 初始化失败。

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct