From ca77fa83be1d49c60638eb4ef217246f60c11f5f Mon Sep 17 00:00:00 2001
From: mmichalek <mmichalek@jumpmind.com>
Date: Fri, 3 Nov 2017 14:56:39 -0400
Subject: [PATCH] Tweak fix

---
 .../jumpmind/symmetric/service/impl/OutgoingBatchService.java   | 2 +-
 1 file changed, 1 insertion(+), 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
index 61a25176ba..7fc4dbae76 100644
--- 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");