diff --git a/storm-core/src/jvm/org/apache/storm/testing/FixedTupleSpout.java b/storm-core/src/jvm/org/apache/storm/testing/FixedTupleSpout.java index 87fc52d1f59..6674676ce8f 100644 --- a/storm-core/src/jvm/org/apache/storm/testing/FixedTupleSpout.java +++ b/storm-core/src/jvm/org/apache/storm/testing/FixedTupleSpout.java @@ -34,15 +34,15 @@ public class FixedTupleSpout implements IRichSpout { private static final Map acked = new HashMap(); private static final Map failed = new HashMap(); - public static int getNumAcked(String stormId) { + public int getNumAcked() { synchronized(acked) { - return get(acked, stormId, 0); + return acked.get(_id); } } - public static int getNumFailed(String stormId) { + public int getNumFailed() { synchronized(failed) { - return get(failed, stormId, 0); + return failed.get(_id); } }