From b1c829afb46fc6d505c58a4938901061e3fb38fc Mon Sep 17 00:00:00 2001
From: brightchen <bright@datatorrent.com>
Date: Tue, 8 Nov 2016 10:53:43 -0800
Subject: [PATCH] APEXMALHAR-2331 #resolve #comment StateTracker#bucketAccessed
 should add bucket to bucketAccessTimes

---
 .../org/apache/apex/malhar/lib/state/managed/StateTracker.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/StateTracker.java b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/StateTracker.java
index 56781074a9..aff13a7f6a 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/StateTracker.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/StateTracker.java
@@ -79,6 +79,7 @@ void bucketAccessed(long bucketId)
       bucketHeap.remove(idTimeWrapper);
     }  else {
       idTimeWrapper = new BucketIdTimeWrapper(bucketId);
+      bucketAccessTimes.put(bucketId, idTimeWrapper);
     }
     idTimeWrapper.setLastAccessedTime(System.currentTimeMillis());
     bucketHeap.add(idTimeWrapper);