diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriter.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriter.java
index 6932175e13..0344c904dd 100644
--- a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriter.java
+++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriter.java
@@ -1029,6 +1029,9 @@ protected Table lookupTableAtTarget(Table sourceTable) {
                 if (table != null) {
                     table = table.copyAndFilterColumns(sourceTable.getColumnNames(),
                             sourceTable.getPrimaryKeyColumnNames(), writerSettings.isUsePrimaryKeysFromSource());
+                    if (table.getPrimaryKeyColumnCount() == 0) {
+                        table = getPlatform(table).makeAllColumnsPrimaryKeys(table);
+                    }
                     Column[] columns = table.getColumns();
                     for (Column column : columns) {
                         if (column != null) {