JeremyXin opened a new issue, #9584: URL: https://github.com/apache/seatunnel/issues/9584
### 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 <img width="1162" height="614" alt="Image" src="https://github.com/user-attachments/assets/36629c4e-5633-4b98-92d9-4d12c07738c5"; /> connector-clickhouse 以sql模式执行时报错： 2025-07-17 17:46:41,665 WARN [h.i.m.i.MetricsCollectionCycle] [hz.main.generic-operation.thread-12] - Collecting metrics from source org.apache.seatunnel.engine.server.TaskExecutionService failed com.hazelcast.internal.metrics.impl.LongWordException: Too long value in the metric descriptor found, maximum is 255: SourceReceivedBytesPerSeconds#SELECT * FROM (select * from xxx.xxxwhere toDate(log_time) = '2025-07-16') AS t ORDER BY xxx LIMIT 296227, 100000 WITH TIES at com.hazelcast.internal.metrics.impl.MetricsDictionary.getDictionaryId(MetricsDictionary.java:50) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCompressor.getDictionaryId(MetricsCompressor.java:260) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCompressor.writeDescriptor(MetricsCompressor.java:177) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCompressor.addDouble(MetricsCompressor.java:157) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] ### SeaTunnel Version 2.3.11 ### SeaTunnel Config ```conf env { parallelism = 24 job.mode = "BATCH" } source { Clickhouse { host = "xxx" table_path = "xxx.xxx" username = "xxx" password = "xxx" sql = "select * from xxx.xxx where toDate(log_time) = '2025-07-16'" batch_size = 100000 } } sink { Console { } } ``` ### Running Command ```shell sh bin/seatunnel.sh --config config/v2.ck.conf - m local ``` ### Error Exception ```log 2025-07-17 17:47:39,941 WARN [o.a.s.e.s.TaskExecutionService] [hz.main.generic-operation.thread-46] - [localhost]:5801 [seatunnel-248576] [5.1] Dynamic metric collection failed com.hazelcast.internal.metrics.impl.LongWordException: Too long value in the metric descriptor found, maximum is 255: SourceReceivedBytesPerSeconds#SELECT * FROM (select * from mail_base_metrics_se.dwd_mail_users_joined_local where toDate(log_time) = '2025-07-16') AS t ORDER BY log_time, event_time, key, map_device_id, map_uid, map_dashi_uid LIMIT 784908, 100000 WITH TIES at com.hazelcast.internal.metrics.impl.MetricsDictionary.getDictionaryId(MetricsDictionary.java:50) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCompressor.getDictionaryId(MetricsCompressor.java:260) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCompressor.writeDescriptor(MetricsCompressor.java:177) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCompressor.addDouble(MetricsCompressor.java:157) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at org.apache.seatunnel.engine.server.metrics.JobMetricsCollector.collectDouble(JobMetricsCollector.java:78) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCollectionCycle$MetricsContext.collect(MetricsCollectionCycle.java:208) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at org.apache.seatunnel.engine.server.metrics.SeaTunnelMetricsContext.lambda$provideDynamicMetrics$0(SeaTunnelMetricsContext.java:49) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at java.util.concurrent.ConcurrentHashMap.forEach(ConcurrentHashMap.java:1597) ~[?:1.8.0_192] at org.apache.seatunnel.engine.server.metrics.SeaTunnelMetricsContext.provideDynamicMetrics(SeaTunnelMetricsContext.java:39) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.provideDynamicMetrics(SeaTunnelTask.java:422) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at org.apache.seatunnel.engine.server.TaskExecutionService.lambda$null$7(TaskExecutionService.java:564) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608) ~[?:1.8.0_192] at org.apache.seatunnel.engine.server.TaskExecutionService.lambda$provideDynamicMetrics$8(TaskExecutionService.java:556) ~[seatunnel-starter.jar:2.3.12-SNAPSHOT] at java.util.HashMap.forEach(HashMap.java:1289) ~[?:1.8.0_192] at org.apache.seatunnel.engine.server.TaskExecutionService.provideDynamicMetrics(TaskExecutionService.java:539) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsCollectionCycle.collectDynamicMetrics(MetricsCollectionCycle.java:88) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.metrics.impl.MetricsRegistryImpl.collect(MetricsRegistryImpl.java:317) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at org.apache.seatunnel.engine.server.task.operation.GetTaskGroupMetricsOperation.run(GetTaskGroupMetricsOperation.java:68) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) [seatunnel-starter.jar:2.3.12-SNAPSHOT] at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) [seatunnel-starter.jar:2.3.12-SNAPSHOT] ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots <img width="1162" height="629" alt="Image" src="https://github.com/user-attachments/assets/9ceeadff-cfe6-40c1-a766-e14116781002"; /> ### 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](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]
