wuwu20048 opened a new issue, #7743: URL: https://github.com/apache/seatunnel/issues/7743
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### 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 ```conf # Defining the runtime environment env { parallelism = 2 job.mode = "STREAMING" job.log_level = "DEBUG" } source { Kafka { schema = { fields { beanName = "string" method = "string" serverId = "string" serverIp = "string" domain = "string" logDate = "string" ceateDate = "string" ipAddress = "string" urt = "int" referer = "string" uri = "string" region = "string" clientId = "int" entrance = "string" source = "string" contentMd5 = "string" timeCost = "int" exceptionCode = "string" contentLength = "int" resultLength = "int" host = "string" } } format = json topic = "gateway_logs" bootstrap.servers = "172.16.22.200:9092" consumer.group = "test" result_table_name="gateway_logs" kafka.config = { client.id = client_1 max.poll.records = 500 auto.offset.reset = "latest" enable.auto.commit = "true" } } } sink { Clickhouse { host = "172.22.1.73:8123" database = "default" table = "logs_local" username = "default" password = "XXXXXX" bulk_size = 1000 source_table_name = "gateway_logs" clickhouse.config = { max_rows_to_read = "100" read_overflow_mode = "throw" } } } ``` ### Running Command ```shell ./bin/seatunnel.sh --config ./config/kafka_ck.template -m local ``` ### Error Exception ```log 024-09-25 17:33:12,238 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel-997458] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2024-09-25 17:33:12,238 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2024-09-25 17:33:12,238 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-997458] [5.1] [localhost]:5801 is SHUTTING_DOWN 2024-09-25 17:33:12,242 INFO [c.h.i.p.i.MigrationManager ] [hz.main.cached.thread-14] - [localhost]:5801 [seatunnel-997458] [5.1] Shutdown request of Member [localhost]:5801 - 3f92f308-4697-43a5-9ff3-caa86572cf5c this master is handled 2024-09-25 17:33:12,246 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-997458] [5.1] Shutting down connection manager... 2024-09-25 17:33:12,248 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-997458] [5.1] Shutting down node engine... 2024-09-25 17:33:12,253 INFO [.c.c.DefaultClassLoaderService] [main] - close classloader service 2024-09-25 17:33:12,254 INFO [o.a.s.e.s.TaskExecutionService] [event-forwarder-0] - [localhost]:5801 [seatunnel-997458] [5.1] Event forward thread interrupted 2024-09-25 17:33:15,262 INFO [c.h.i.i.NodeExtension ] [main] - [localhost]:5801 [seatunnel-997458] [5.1] Destroying node NodeExtension. 2024-09-25 17:33:15,263 INFO [c.h.i.i.Node ] [main] - [localhost]:5801 [seatunnel-997458] [5.1] Hazelcast Shutdown is completed in 3022 ms. 2024-09-25 17:33:15,263 INFO [c.h.c.LifecycleService ] [main] - [localhost]:5801 [seatunnel-997458] [5.1] [localhost]:5801 is SHUTDOWN 2024-09-25 17:33:15,263 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed HazelcastInstance ...... 2024-09-25 17:33:15,263 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2024-09-25 17:33:15,263 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2024-09-25 17:33:15,263 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-09-25 17:33:15,263 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2024-09-25 17:33:15,267 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:211) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: java.lang.ArrayIndexOutOfBoundsException: 2 at com.clickhouse.client.data.ClickHouseSimpleRecord.getValue(ClickHouseSimpleRecord.java:86) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseProxy.lambda$getClickhouseTableSchema$2(ClickhouseProxy.java:144) at java.lang.Iterable.forEach(Iterable.java:75) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseProxy.getClickhouseTableSchema(ClickhouseProxy.java:142) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseProxy.getClickhouseTableSchema(ClickhouseProxy.java:133) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseSink.prepare(ClickhouseSink.java:145) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSink(JobConfigParser.java:167) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSinks(JobConfigParser.java:137) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:560) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:221) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:158) ... 2 more 2024-09-25 17:33:15,267 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:211) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: java.lang.ArrayIndexOutOfBoundsException: 2 at com.clickhouse.client.data.ClickHouseSimpleRecord.getValue(ClickHouseSimpleRecord.java:86) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseProxy.lambda$getClickhouseTableSchema$2(ClickhouseProxy.java:144) at java.lang.Iterable.forEach(Iterable.java:75) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseProxy.getClickhouseTableSchema(ClickhouseProxy.java:142) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseProxy.getClickhouseTableSchema(ClickhouseProxy.java:133) at org.apache.seatunnel.connectors.seatunnel.clickhouse.sink.client.ClickhouseSink.prepare(ClickhouseSink.java:145) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSink(JobConfigParser.java:167) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSinks(JobConfigParser.java:137) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:560) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:221) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:158) ... 2 more ➜ apache-seatunnel-2.3.7 ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version jdk 1.8 ### Screenshots  ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
