YuriyGavrilov
commented
4 days ago Hi @wuwu20048 This works for me on seatunnel v 2.3.8. java Azul 17
CREATE TABLE default.sink_table
(
id int, name String, out String
)
ENGINE = MergeTree ORDER BY id
# Set the basic configuration of the task to be performed
env {
parallelism = 1
job.mode = "BATCH"
}
source {
FakeSource {
row.num = 6
schema = {
fields {
id = "int"
name = "string"
out = "string"
}
}
rows = [
{fields = [1, "Jia Fan", "ffrrr"], kind = INSERT}
{fields = [2, "Hailin Wang", "ddd"], kind = INSERT}
{fields = [3, "Tomas", "vfs"], kind = INSERT}
{fields = [4, "Eric", "kfkd"], kind = INSERT}
{fields = [5, "Guangdong Liu", "pew"], kind = INSERT}
{fields = [6, "Юрий Гаврилов", "szs"], kind = INSERT}
]
}
}
#transform {
#}
sink {
Clickhouse {
host = "some-clickhouse-server:8123"
database = "default"
table = "sink_table"
username = ""
password = ""
bulk_size = 1000
# source_table_name = "gateway_logs"
clickhouse.config = {
max_rows_to_read = "100"
read_overflow_mode = "throw"
}
}
}
wuwu20048
Search before asking
What happened
kafka import to the clickhouse reported an error . is the clickhouse version too old ? the version is 20.3.19.4
SeaTunnel Version
2.3.7
SeaTunnel Config
Running Command
Error Exception
Zeta or Flink or Spark Version
No response
Java or Scala Version
jdk 1.8
Screenshots
Are you willing to submit PR?
Code of Conduct