diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/db2/Db2SymmetricDialect.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/db2/Db2SymmetricDialect.java
index 1616c6ef0d..a125738051 100644
--- a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/db2/Db2SymmetricDialect.java
+++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/db2/Db2SymmetricDialect.java
@@ -119,6 +119,8 @@ public BinaryEncoding getBinaryEncoding() {
     }
 
     public void enableSyncTriggers(ISqlTransaction transaction) {
+        transaction.prepareAndExecute("set " + parameterService.getTablePrefix() + VAR_TRIGGER_DISABLED + " = null");
+        transaction.prepareAndExecute("set " + getSourceNodeExpression() + " = null");
     }
 
     public void disableSyncTriggers(ISqlTransaction transaction, String nodeId) {
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/sqlite/SqliteSymmetricDialect.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/sqlite/SqliteSymmetricDialect.java
index 1a441717d8..1d4f92491f 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/sqlite/SqliteSymmetricDialect.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/sqlite/SqliteSymmetricDialect.java
@@ -89,7 +89,7 @@ public void enableSyncTriggers(ISqlTransaction transaction) {
     public String getSyncTriggersExpression() {
         if (isBlank(sqliteFunctionToOverride)) {
             String contextTableName = parameterService.getTablePrefix() + "_" + TableConstants.SYM_CONTEXT;
-            return "(not exists (select value from " + contextTableName + " where name = '" + SYNC_TRIGGERS_DISABLED_USER_VARIABLE + "'))";
+            return "(not exists (select context_value from " + contextTableName + " where name = '" + SYNC_TRIGGERS_DISABLED_USER_VARIABLE + "'))";
         } else {
             return "(" + sqliteFunctionToOverride + "() not like 'DISABLED%')";
         }