[Bugfix]fix clickhouse source connector read Nullable() type is not n…

…ull,example:Nullable(Float64) while value is null the result is 0.0 (#5080)
apache · Jul 14, 2023 · cf3d0bb · cf3d0bb
1 parent 53faa5f
commit cf3d0bb
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/...a/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSourceReader.java b/...a/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));
                                 });