[Fix] Fix get bytes size NPE in SeaTunnelRow (apache#314)

ruanwenjun · Sep 2, 2023 · 43e0de0 · 43e0de0
1 parent 9ab2083
commit 43e0de0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java
@@ -113,7 +113,9 @@ public int getBytesSize(SeaTunnelRowType rowType) {
 
     /** faster version of {@link #getBytesSize(SeaTunnelRowType)}. */
     private int getBytesForValue(Object v, SeaTunnelDataType<?> dataType) {
-
+        if (v == null) {
+            return 0;
+        }
         SqlType sqlType = dataType.getSqlType();
         switch (sqlType) {
             case STRING: