commit d3f7faf58bff06a3c670241542476d1d4a07386f
author ajaygit158 <ajaygit158@gmail.com> Wed Jun 14 11:35:06 2017 +0530
committer Tushar R. Gosavi <tushargosavi@gmail.com> Thu Sep 07 10:09:31 2017 +0530
tree b4f3de3f738eaa8e278bee6f2c1ed4b9f0e0ed2c
parent 6416344d8092d6c1d9607b78ef2fff33757951c4

APEXMALHAR-2508 Add null check while calling cancel() for Timer instance in CacheManager

library/src/main/java/com/datatorrent/lib/db/cache/CacheManager.java

diff --git a/library/src/main/java/com/datatorrent/lib/db/cache/CacheManager.java b/library/src/main/java/com/datatorrent/lib/db/cache/CacheManager.java
index 4724761..869302b 100644
--- a/library/src/main/java/com/datatorrent/lib/db/cache/CacheManager.java
+++ b/library/src/main/java/com/datatorrent/lib/db/cache/CacheManager.java
@@ -177,7 +177,9 @@
   @Override
   public void close() throws IOException
   {
-    refresher.cancel();
+    if (refresher != null) {
+      refresher.cancel();
+    }
     primary.disconnect();
     backup.disconnect();
   }