comments

Author: ArnavBalyan

parquet-cli/pom.xml

@@ -85,26 +85,28 @@
       <artifactId>parquet-avro</artifactId>
       <version>${project.version}</version>
     </dependency>
+
+    <!-- Protobuf dependencies for CLI Tests -->
     <dependency>
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-protobuf</artifactId>
       <version>${project.version}</version>
       <classifier>tests</classifier>
       <scope>test</scope>
     </dependency>
-    <!-- CatCommandTest (for TestProtobuf) -->
     <dependency>
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java</artifactId>
       <version>3.25.6</version>
-      <scope>${deps.scope}</scope>
+      <scope>test</scope>
     </dependency>
     <dependency>
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-protobuf</artifactId>
       <version>${project.version}</version>
-      <scope>${deps.scope}</scope>
+      <scope>test</scope>
     </dependency>
+
     <dependency>
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-format-structures</artifactId>

parquet-cli/src/main/java/org/apache/parquet/cli/util/Schemas.java

@@ -82,7 +82,8 @@ public static Schema fromParquet(Configuration conf, URI location) throws IOExce
     if (schemaString != null) {
       return new Schema.Parser().parse(schemaString);
     } else {
-      return new AvroSchemaConverter().convert(footer.getFileMetaData().getSchema());
+      return new AvroSchemaConverter(conf)
+          .convert(footer.getFileMetaData().getSchema());
     }
   }
 

parquet-cli/src/test/java/org/apache/parquet/cli/commands/CatCommandTest.java

@@ -82,13 +82,15 @@ public void testCatCommandProtoParquetAutoDetected() throws Exception {
   }
 
   @Test
-  public void testCatCommandProtoParquetSucceedsWithAutoDetection() throws Exception {
-    File protoFile = new File(getTempFolder(), "proto_someevent.parquet");
-    writeProtoParquet(protoFile);
+  public void testCatCommandWithSimpleReaderConfig() throws Exception {
+    File regularFile = parquetFile();
 
-    CatCommand cmd = new CatCommand(createLogger(), 0);
-    cmd.sourceFiles = Arrays.asList(protoFile.getAbsolutePath());
-    cmd.setConf(new Configuration());
+    Configuration conf = new Configuration();
+    conf.setBoolean("parquet.enable.simple-reader", true);
+
+    CatCommand cmd = new CatCommand(createLogger(), 5);
+    cmd.sourceFiles = Arrays.asList(regularFile.getAbsolutePath());
+    cmd.setConf(conf);
 
     int result = cmd.run();
     Assert.assertEquals(0, result);