0003091: A corrupt batch being sent to a target results in a

NullPointerException by load writing the batch to staging
JumpMind · May 4, 2017 · 4cad934 · 4cad934
1 parent a0badaa
commit 4cad934
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...etric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java b/...etric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java
@@ -174,6 +174,9 @@ public void process() throws IOException {
             } else if (line.startsWith(CsvConstants.CHANNEL)) {
                 channelLine = line;
             } else {
+                if (writer == null) {
+                    throw new IllegalStateException("Invalid batch data was received: " + line);
+                }
                 TableLine batchLine = batchTableLines.get(tableLine);
                 if (batchLine == null || (batchLine != null && batchLine.columnsLine == null)) {
                     TableLine syncLine = syncTableLines.get(tableLine);