Fix nullable check.

snowflakedb · Jul 25, 2024 · 3325c1d · 3325c1d
1 parent d599cb6
commit 3325c1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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");
       }