diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/IcebergParquetValueParser.java b/src/main/java/net/snowflake/ingest/streaming/internal/IcebergParquetValueParser.java
index d361830b9..7ba0d799b 100644
--- a/src/main/java/net/snowflake/ingest/streaming/internal/IcebergParquetValueParser.java
+++ b/src/main/java/net/snowflake/ingest/streaming/internal/IcebergParquetValueParser.java
@@ -138,7 +138,7 @@ static ParquetBufferValue parseColumnValueToParquet(
     }
 
     if (value == null) {
-      if (!type.isRepetition(Repetition.REQUIRED)) {
+      if (type.isRepetition(Repetition.REQUIRED)) {
         throw new SFException(
             ErrorCode.INVALID_FORMAT_ROW, type.getName(), "Passed null to non nullable field");
       }