diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java
index e80a88b8c3..0a4e594b49 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java
@@ -189,7 +189,7 @@ public void unlock(final String action) {
 
     protected boolean unlock(String action, String serverId) {
         String lastLockingServerId = serverId.equals(Lock.STOPPED) ? null : serverId;
-        return sqlTemplate.update(getSql("releaseLockSql"), new Object[] { lastLockingServerId, action,
+        return sqlTemplate.update(getSql("releaseLockSql"), new Object[] { new Date(), lastLockingServerId, action,
                 serverId }) > 0;
     }
 
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterServiceSqlMap.java
index 694660d6a6..6c47489372 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterServiceSqlMap.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterServiceSqlMap.java
@@ -36,7 +36,7 @@ public ClusterServiceSqlMap(IDatabasePlatform platform, Map<String, String> repl
 
         putSql("releaseLockSql",
                 ""
-                        + "update $(lock) set locking_server_id=null, lock_time=null, last_lock_time=current_timestamp, last_locking_server_id=?   "
+                        + "update $(lock) set locking_server_id=null, lock_time=null, last_lock_time=?, last_locking_server_id=?   "
                         + "  where lock_action=? and locking_server_id=?                                                                                 ");
 
         putSql("insertLockSql", "" + "insert into $(lock) (lock_action) values(?)   ");