[FLINK-10355] [java] Use 1-based field indexes in RowCsvInputFormat e…

…xception messages. This closes apache#6713.
tongcheng-elong · Sep 20, 2018 · e58cc14 · e58cc14
1 parent c15ba1c
commit e58cc14
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java b/flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java
@@ -177,7 +177,7 @@ protected boolean parseRecord(Object[] holders, byte[] bytes, int offset, int nu
  // the error state EMPTY_COLUMN is ignored
  if (parser.getErrorState() != FieldParser.ParseErrorState.EMPTY_COLUMN) {
  throw new ParseException(String.format("Parsing error for column %1$s of row '%2$s' originated by %3$s: %4$s.",
- field, new String(bytes, offset, numBytes), parser.getClass().getSimpleName(), parser.getErrorState()));
+ field + 1, new String(bytes, offset, numBytes), parser.getClass().getSimpleName(), parser.getErrorState()));
  }
  }
  holders[fieldPosMap[output]] = parser.getLastResult();
@@ -199,7 +199,7 @@ protected boolean parseRecord(Object[] holders, byte[] bytes, int offset, int nu
  // check if something went wrong
  if (startPos < 0) {
  throw new ParseException(String.format("Unexpected parser position for column %1$s of row '%2$s'",
- field, new String(bytes, offset, numBytes)));
+ field + 1, new String(bytes, offset, numBytes)));
  }
  else if (startPos == limit
  && field != fieldIncluded.length - 1