Support RowKind(DELETE/UPDATE_AFTER) data row in JDBC sink not working.

[sangeetha1706]

Search before asking

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

What happened

when im inserting or updating or deleting anything RowKind=INSERT/UPDATE/DELETE not writing the CDC change in console.

SeaTunnel Version

apache-seatunnel-incubating-2.3.1

SeaTunnel Config

env {
   job.mode = "STREAMING"
}
source {
  MySQL-CDC {
    result_table_name = "SINK_USER"
    parallelism = 1
    server-id = 5656
    snapshot.fetch.size = 3
    username = ""
    password = ""
    table-names = ["TEST.SOURCE_USER"]
    base-url = "jdbc:mysql://10.0.14.66:3306/TEST"
}
}
sink {
Console
{
source_table_name="SOURCE_USER"
}
}
sink{
jdbc {
        url = "jdbc:mysql://10.0.14.66:3306/TEST"
        driver = "com.mysql.cj.jdbc.Driver"
        user = ""
         password = ""
        database = "TEST"
        primary_keys = ["ID"]
        table = SINK_USER

}
}

Running Command

./bin/seatunnel.sh --config ./config/MYSQL-CDC.conf -e local

Error Exception

.

Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

• [X] Yes I am willing to submit a PR!

Code of Conduct

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

[github-actions[bot]]

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.