[Feature][connector-clickhouse] 类型转换失败，打印具体失败列和完成日志对象

1 files changed, 2 insertions, 1 deletions

diff --git a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/sink/EventBatchIntervalClickHouseSink.java b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/sink/EventBatchIntervalClickHouseSink.java
index 3abacbe..b4cf0bb 100644
--- a/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/sink/EventBatchIntervalClickHouseSink.java
+++ b/groot-connectors/connector-clickhouse/src/main/java/com/geedgenetworks/connectors/clickhouse/sink/EventBatchIntervalClickHouseSink.java
@@ -1,5 +1,6 @@
 package com.geedgenetworks.connectors.clickhouse.sink;
 
+import com.alibaba.fastjson2.JSON;
 import com.geedgenetworks.core.pojo.Event;
 
 import com.github.housepower.data.Block;
@@ -31,7 +32,7 @@ public class EventBatchIntervalClickHouseSink extends AbstractBatchIntervalClick
                 try {
                     batch.setObject(i, columnConverters[i].convert(value));
                 } catch (Exception e) {
-                    throw new RuntimeException(columnNames[i] + "列转换值出错:" + value + ", event data:" + map, e);
+                    throw new RuntimeException(columnNames[i] + "列转换值出错:" + value + ", event data:" + JSON.toJSONString(map), e);
                 }
             }
         }