seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

[Bug] [Connector-V2] fix jdbc-multi-metrics bug

Open corgy-w opened this issue 6 months ago • 0 comments

Search before asking

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

What happened

There is no table_path multi-metrics populating error. -> eg:

"TableSinkWriteBytes": {
      "default.default.default": "18176",
      "default.default.default": "7028"
    }

Jdbc table-path to be named correctly when catalog is created. ->res:

"TableSinkWriteBytes": {
      "dbs.user": "18176",
      "dbs.users": "7028"
    }

SeaTunnel Version

dev

SeaTunnel Config

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

}
transform {
}
sink {
    Jdbc {
        url="jdbc:mysql://xxxxxx: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="xxxxxx."
        database="pegasus_data_demo_00"
        table="user"
         generate_sink_sql = true
        source_table_name="mysql1"
    }
    Jdbc {
        url="jdbc:mysql://xxxxxx: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="xxxxxx."
        database="pegasus_data_demo_00"
        table="users"
        generate_sink_sql = true
        source_table_name="mysql2"
    }

}

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

corgy-w avatar Aug 24 '24 07:08 corgy-w