Merge pull request #13 from embulk/fix-exception-handling-with-older

Fix Exception handling to be the same with older embulk-parser-csv
embulk · Nov 18, 2023 · 959cedb · 959cedb
2 parents 022e387 + 40b530a
commit 959cedb
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/src/main/java/org/embulk/parser/csv/CsvParserPlugin.java b/src/main/java/org/embulk/parser/csv/CsvParserPlugin.java
@@ -338,13 +338,9 @@ public void run(TaskSource taskSource, final Schema schema,
                     }
                 }
 
-                try {
-                    if (!tokenizer.nextRecord()) {
-                        // empty file
-                        continue;
-                    }
-                } catch (final InvalidCsvFormatException ex) {
-                    throw new DataException(ex);
+                if (!tokenizer.nextRecord()) {
+                    // empty file
+                    continue;
                 }
 
                 while (true) {
@@ -473,6 +469,8 @@ private String nextColumn() {
             }
 
             pageBuilder.finish();
+        } catch (final InvalidCsvFormatException ex) {
+            throw new DataException(ex);
         }
     }