diff --git a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
index 8d3de88abb8..bb4d3905ee8 100644
--- a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
+++ b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java
@@ -83,10 +83,14 @@ record -> {
                                     Object[] values =
                                             new Object[this.rowTypeInfo.getFieldNames().length];
                                     for (int i = 0; i < record.size(); i++) {
-                                        values[i] =
-                                                TypeConvertUtil.valueUnwrap(
-                                                        this.rowTypeInfo.getFieldType(i),
-                                                        record.getValue(i));
+                                        if (record.getValue(i).isNullOrEmpty()) {
+                                            values[i] = null;
+                                        } else {
+                                            values[i] =
+                                                    TypeConvertUtil.valueUnwrap(
+                                                            this.rowTypeInfo.getFieldType(i),
+                                                            record.getValue(i));
+                                        }
                                     }
                                     output.collect(new SeaTunnelRow(values));
                                 });