commit 7279f06b43bf1200c60f5d9668ef3a1f345d85ad
author Jason Jackson <jackson@twitter.com> Thu May 09 01:00:47 2013 -0700
committer Nathan Marz <nathan@nathanmarz.com> Wed May 29 13:45:21 2013 -0700
tree 847a7ec5b710c4ebdfd86155a63e2ae65fddd499
parent dc8a3d10c38bfaac429b30a3dbd1b08294261a17

Ignore NoNodeExists exceptions

src/jvm/storm/trident/topology/state/RotatingTransactionalState.java

diff --git a/src/jvm/storm/trident/topology/state/RotatingTransactionalState.java b/src/jvm/storm/trident/topology/state/RotatingTransactionalState.java
index a44e24c..2ffe680 100644
--- a/src/jvm/storm/trident/topology/state/RotatingTransactionalState.java
+++ b/src/jvm/storm/trident/topology/state/RotatingTransactionalState.java
@@ -1,5 +1,7 @@
 package storm.trident.topology.state;
 
+import org.apache.zookeeper.KeeperException;
+
 import java.util.HashSet;
 import java.util.List;
 import java.util.SortedMap;
@@ -87,7 +89,16 @@
         SortedMap<Long, Object> toDelete = _curr.headMap(txid);
         for(long tx: new HashSet<Long>(toDelete.keySet())) {
             _curr.remove(tx);
-            _state.delete(txPath(tx));
+            try {
+                _state.delete(txPath(tx));
+            } catch(RuntimeException e) {
+                // Ignore NoNodeExists exceptions because when sync() it may populate _curr with stale data since
+                // zookeeper reads are eventually consistent.
+                if(!(e.getCause() instanceof KeeperException.NoNodeException)) {
+                    throw e;
+                }
+            }
+
         }
     }