diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/PostgresBulkDatabaseWriter.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/PostgresBulkDatabaseWriter.java index 240a25a281..d7ded62be8 100644 --- a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/PostgresBulkDatabaseWriter.java +++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/PostgresBulkDatabaseWriter.java @@ -83,7 +83,7 @@ protected void bulkWrite(CsvData data) { } } } - + useDefaultDataWriter=false; switch (dataEventType) { case INSERT: startCopy(); @@ -114,6 +114,7 @@ protected void bulkWrite(CsvData data) { case DELETE: default: endCopy(); + useDefaultDataWriter=true; super.write(data); break; }