[parquet-mr] branch master updated: PARQUET-2330: Fix convert-csv to show the correct position of the invalid record (#1127)

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gangwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/parquet-mr.git


The following commit(s) were added to refs/heads/master by this push:
     new 515734c37 PARQUET-2330: Fix convert-csv to show the correct position of the invalid record (#1127)
515734c37 is described below

commit 515734c373f69b5250e8b63eb3d1c973da893b63
Author: Kengo Seki <se...@apache.org>
AuthorDate: Thu Aug 3 23:29:53 2023 +0900

    PARQUET-2330: Fix convert-csv to show the correct position of the invalid record (#1127)
---
 .../src/main/java/org/apache/parquet/cli/commands/ConvertCSVCommand.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/parquet-cli/src/main/java/org/apache/parquet/cli/commands/ConvertCSVCommand.java b/parquet-cli/src/main/java/org/apache/parquet/cli/commands/ConvertCSVCommand.java
index 941583e37..f989daa9a 100644
--- a/parquet-cli/src/main/java/org/apache/parquet/cli/commands/ConvertCSVCommand.java
+++ b/parquet-cli/src/main/java/org/apache/parquet/cli/commands/ConvertCSVCommand.java
@@ -181,6 +181,7 @@ public class ConvertCSVCommand extends BaseCommand {
           .build()) {
         for (Record record : reader) {
           writer.write(record);
+          count++;
         }
       } catch (RuntimeException e) {
         throw new RuntimeException("Failed on record " + count, e);