Update parquet-format-structures/src/main/java/org/apache/parquet/format/Util.java

cravani · Fokko · web-flow · commit 082f7bb64caa · 2025-11-24T15:29:45.000+01:00
Co-authored-by: Fokko Driesprong &lt;fokko@apache.org&gt;
diff --git a/parquet-format-structures/src/main/java/org/apache/parquet/format/Util.java b/parquet-format-structures/src/main/java/org/apache/parquet/format/Util.java
@@ -417,8 +417,8 @@ private static InterningProtocol protocol(TIOStreamTransport t, int configuredMa
       // Set to default 100 MB
       maxMessageSize = DEFAULT_MAX_MESSAGE_SIZE;
     }
-    if (configuredMaxMessageSize < -1 || configuredMaxMessageSize == 0) {
-      throw new NumberFormatException("Invalid max message size: " + configuredMaxMessageSize);
+    if (configuredMaxMessageSize <= 0) {
+      throw new NumberFormatException("Max message size must be positive: " + configuredMaxMessageSize);
     }
 
     TConfiguration config = t.getConfiguration();

Original file line number	Diff line number	Diff line change
`@@ -417,8 +417,8 @@ private static InterningProtocol protocol(TIOStreamTransport t, int configuredMa`
`417`	`417`	`// Set to default 100 MB`
`418`	`418`	`maxMessageSize = DEFAULT_MAX_MESSAGE_SIZE;`
`419`	`419`	`}`
`420`		`- if (configuredMaxMessageSize < -1 \|\| configuredMaxMessageSize == 0) {`
`421`		`- throw new NumberFormatException("Invalid max message size: " + configuredMaxMessageSize);`
	`420`	`+ if (configuredMaxMessageSize <= 0) {`
	`421`	`+ throw new NumberFormatException("Max message size must be positive: " + configuredMaxMessageSize);`
`422`	`422`	`}`
`423`	`423`
`424`	`424`	`TConfiguration config = t.getConfiguration();`