add cache policy update to compare collection executor
@@ -75,6 +75,7 @@ public class CompareCollectionExecutor implements CollectionExecutor {
return returnEventChunk.getFirst();
} else {
for (StreamEvent storeEvent : storeEventSet) {
+ cacheTable.updateCachePolicyAttribute(storeEvent);
if (storeEventCloner != null) {
returnEventChunk.add(storeEventCloner.copyStreamEvent(storeEvent));
} else {
