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 <[email protected]>
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);