seatunnel
seatunnel copied to clipboard
[Bug] can not execute myssql-to-clickhouse job
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
Run Error!when use seatunnel run mysql-to-clickhouse command; but mysql-to-mysql is success!
SeaTunnel Version
2.3.3
SeaTunnel Config
# Set the basic configuration of the task to be performed
env {
execution.parallelism = 1
job.mode = "BATCH"
checkpoint.interval = 1000
}
source {
Jdbc {
url = "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT%2b8"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "123456"
query = "SELECT `id`, `username`, `info`, `age` FROM `users`"
parallelism=1
connection_check_timeout_sec=30
result_table_name=Tableuser
}
}
sink {
Clickhouse {
host = "127.0.0.1:8123"
database = "default"
table = "test"
username = "default"
password = ""
}
}
Running Command
sh bin/seatunnel.sh --config config/xxx.conf -m local
Error Exception
java.util.concurrent.CompletionException: com.hazelcast.nio.serialization.HazelcastSerializationException: java.lang.ClassCastException: cannot assign instance of com.clickhouse.client.ClickHouseNode to field org.apache.seatunnel.connectors.seatunnel.clickhouse.shard.Shard.node of type com.clickhouse.client.ClickHouseNode in instance of org.apache.seatunnel.connectors.seatunnel.clickhouse.shard.Shard
Zeta or Flink or Spark Version
seatunnel 2.3.3
Java or Scala Version
java 1.8
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
用flink cdc吧。这个bug太多了。
@wjhphp hi,Can you give us more information,will you contribute to this?
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.
?
i have the same question too