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
index 1cd2636c21c..bd05e0808d8 100644
--- 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: