Tweak fix

JumpMind · Nov 3, 2017 · ca77fa8 · ca77fa8
1 parent 128a681
commit ca77fa8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
@@ -165,8 +165,8 @@ public void markAllChannelAsSent(String channelId, String tableName) {
             elgibleBatches = sqlTemplateDirty.query(sql, new Object[] { channelId, "OK" });
         }
 
-        String updateSql = getSql("cancelChannelBatchSql");
         if (elgibleBatches != null) {
+            String updateSql = getSql("cancelChannelBatchSql");
             for (Row elgibleBatch : elgibleBatches) {
                 String nodeId = elgibleBatch.getString("node_id");
                 long batchId = elgibleBatch.getLong("batch_id");