Correct in-memory data aggregation logic
The aggregation must be done only if inmemory data exists. Hence we need to check whether the in-memory store 'baseIncrementalValueStore' is already processed.
Otherwise ignore it.
@@ -97,7 +97,7 @@ public class IncrementalDataAggregator {
processInMemoryAggregates(aBaseIncrementalValueStoreList.createStreamEvent(),
aBaseIncrementalValueStoreList.getTimestamp(), null);
}
- } else {
+ } else if (baseIncrementalValueStore.isProcessed()) {
processInMemoryAggregates(baseIncrementalValueStore.createStreamEvent(),
baseIncrementalValueStore.getTimestamp(), null);
}
