fix logging and stage clean in client-mode, fix un-install

JumpMind · Mar 22, 2018 · 6dc4022 · 6dc4022
1 parent a9d70e5
commit 6dc4022
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 6 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java
@@ -36,11 +36,15 @@ protected Map<String, Long> getBiggestBatchIds(List<BatchId> batches) {
 
     @Override
     public long clean(long ttlInMs) {
-        if (!engine.getClusterService().lock(ClusterConstants.STAGE_MANAGEMENT)) {
-            log.debug("Could not get a lock to run stage management");
-            return 0;
+        try {
+            if (!engine.getClusterService().lock(ClusterConstants.STAGE_MANAGEMENT)) {
+                log.debug("Could not get a lock to run stage management");
+                return 0;
+            }
+        } catch (Exception e) {
+            // during setup or un-install, it's possible sym_lock table isn't available yet
         }
-        
+
         try {            
             boolean purgeBasedOnTTL = engine.getParameterService().is(ParameterConstants.STREAM_TO_FILE_PURGE_ON_TTL_ENABLED, false);
             if (purgeBasedOnTTL) {
@@ -51,7 +55,10 @@ public long clean(long ttlInMs) {
                 }
             }
         } finally {
-            engine.getClusterService().unlock(ClusterConstants.STAGE_MANAGEMENT);
+            try {
+                engine.getClusterService().unlock(ClusterConstants.STAGE_MANAGEMENT);
+            } catch (Exception e) {
+            }
         }
     }
 

diff --git a/...pmind/symmetric/web/SymPatternLayout.java → ...pmind/symmetric/web/SymPatternLayout.java b/...pmind/symmetric/web/SymPatternLayout.java → ...pmind/symmetric/web/SymPatternLayout.java
@@ -23,7 +23,6 @@
 import java.util.Date;
 import java.util.List;
 
-import org.apache.commons.lang.time.DateUtils;
 import org.apache.log4j.PatternLayout;
 import org.jumpmind.symmetric.AbstractSymmetricEngine;
 import org.jumpmind.symmetric.ISymmetricEngine;