seatunnel
seatunnel copied to clipboard
[Bug] [Connector-V2] fix jdbc-multi-metrics bug
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
- [X] I agree to follow this project's Code of Conduct