0005602: Parse exception of batch should remove it from staging

JumpMind · Nov 28, 2022 · 0e76685 · 0e76685
1 parent 9d2f042
commit 0e76685
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/reader/ProtocolDataReader.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/reader/ProtocolDataReader.java
@@ -51,6 +51,7 @@
 import org.jumpmind.symmetric.io.data.DataContext;
 import org.jumpmind.symmetric.io.data.DataEventType;
 import org.jumpmind.symmetric.io.data.IDataReader;
+import org.jumpmind.symmetric.io.data.ProtocolException;
 import org.jumpmind.symmetric.io.stage.IStagedResource;
 import org.jumpmind.util.CollectionUtils;
 import org.jumpmind.util.Statistics;
@@ -191,7 +192,7 @@ public Object readNext() {
                                         + "The number of columns (%d) reported for table '%s' doesn't match up with the token count (%d) data: %s",
                                 columnCount, context.getLastParsedTable().getFullyQualifiedTableName(), tokens.length,
                                 ArrayUtils.toString(tokens));
-                        throw new IllegalStateException(msg);
+                        throw new ProtocolException(msg);
                     }
                     data.putParsedData(CsvData.ROW_DATA, CollectionUtils.copyOfRange(tokens, 1, columnCount + 1));
                     data.putParsedData(CsvData.PK_DATA, CollectionUtils.copyOfRange(tokens, columnCount + 1, tokens.length));