0005766: Fixed NPE when inserting into sym_incoming_error on some pla…

…tforms
JumpMind · Apr 24, 2023 · 2550650 · 2550650
1 parent aaa445d
commit 2550650
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -897,7 +897,8 @@ public void insertIncomingError(IncomingError incomingError) {
     public void insertIncomingError(ISqlTransaction transaction, IncomingError incomingError) {
         if (StringUtils.isNotBlank(incomingError.getNodeId()) && incomingError.getBatchId() >= 0) {
             boolean alreadyExists = false;
-            if (symmetricDialect.getDriverName().equalsIgnoreCase(DatabaseNamesConstants.OPENEDGE)) {
+            if (symmetricDialect.getDriverName() != null
+                    && symmetricDialect.getDriverName().equalsIgnoreCase(DatabaseNamesConstants.OPENEDGE)) {
                 if (getIncomingError(incomingError.getBatchId(), incomingError.getNodeId(),
                         incomingError.getFailedRowNumber()) != null) {
                     alreadyExists = true;