[Bug] [Zeta] Metrics value error

[corgy-w]

Search before asking

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

What happened

The failed task indicator is wrong and has no reference significance.

The table with 1000 row for used.

For deliberate failure, the ideal result should be Read:1000 Write: 0

SeaTunnel Version

2.3.8-snapshot

SeaTunnel Config

env {
"job.mode"="BATCH"
"job.name"="20"
}
source {
        Jdbc {
            url="jdbc:mysql://xxxx:3306/dbs?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true"
            driver="com.mysql.cj.jdbc.Driver"
            user="root"
            password="qxin1029."
            query="select name, xx from `dbs`.`users`"
            "batch_size"="1"
            result_table_name="mysql2"
        }

}
transform {
}
sink {
    Jdbc {
        url="jdbc:mysql://xxxx:3306/pegasus_data_demo_00?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true"
        driver="com.mysql.cj.jdbc.Driver"
        user="root"
        password="qxin1029."
        database="pegasus_data_demo_00"
        table="users"
        generate_sink_sql = true
        source_table_name="mysql2"
    }

}

pegasus_data_demo_00.users not have xx field

Running Command

-

Error Exception

-

Zeta or 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