diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
index bc14aa6f4c..90e744da4d 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
@@ -279,7 +279,8 @@ public void insertIncomingBatch(ISqlTransaction transaction, IncomingBatch batch
         if (batch.isPersistable()) {
             boolean alreadyExists = false;
             if (symmetricDialect.getName().equals(DatabaseNamesConstants.REDSHIFT)
-                    || symmetricDialect.getDriverName().equalsIgnoreCase(DatabaseNamesConstants.OPENEDGE)) {
+                    || (symmetricDialect.getDriverName() != null
+                            && symmetricDialect.getDriverName().equalsIgnoreCase(DatabaseNamesConstants.OPENEDGE))) {
                 if (findIncomingBatch(batch.getBatchId(), batch.getNodeId()) != null) {
                     alreadyExists = true;
                 }