Check parquet-mr version

Author: rahulketch

parquet-column/src/main/java/org/apache/parquet/ValidInt96Stats.java

@@ -50,7 +50,7 @@ public static boolean hasValidInt96Stats(String createdBy) {
     try {
       ParsedVersion version = VersionParser.parse(createdBy);
       if ("parquet-mr".equals(version.application)) {
-        return true;
+        return version.version != null && version.version.compareTo("1.15.0") > 0;
       }
       if ("parquet-mr compatible Photon".equals(version.application)) {
         return true;

parquet-column/src/test/java/org/apache/parquet/ValidInt96StatsTest.java

@@ -33,11 +33,24 @@ public void testNullAndEmpty() {
 
   @Test
   public void testParquetMrValid() {
-    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3"));
-    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3 (build abcd)"));
-    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3-SNAPSHOT"));
-    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3rc1"));
-    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3rc1-SNAPSHOT"));
+    // Versions > 1.15.0 should be valid
+    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.16.0"));
+    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.15.1"));
+    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 2.0.0"));
+    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.16.0 (build abcd)"));
+    assertTrue(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.15.1-SNAPSHOT"));
+  }
+
+  @Test
+  public void testParquetMrInvalid() {
+    // Versions <= 1.15.0 should be invalid
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.15.0"));
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3"));
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.14.0"));
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3 (build abcd)"));
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3-SNAPSHOT"));
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3rc1"));
+    assertFalse(ValidInt96Stats.hasValidInt96Stats("parquet-mr version 1.12.3rc1-SNAPSHOT"));
   }
 
   @Test