Merge pull request #1222 from Niveathika92/4.4.x

Clean group by resources from snapshotable services when refreshing reading executors
siddhi-io · Apr 17, 2019 · 640ddfa · 640ddfa
2 parents 43c4718 + 81714fd
commit 640ddfa
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/aggregation/IncrementalExecutor.java b/modules/siddhi-core/src/main/java/org/wso2/siddhi/core/aggregation/IncrementalExecutor.java
@@ -310,6 +310,10 @@ public void setProcessingExecutor(boolean processingExecutor) {
 
     public void clearExecutor() {
         if (isGroupBy) {
+            for (BaseIncrementalValueStore baseIncrementalValueStore :
+                                                                this.baseIncrementalValueStoreGroupByMap.values()) {
+                baseIncrementalValueStore.clean();
+            }
             this.baseIncrementalValueStoreGroupByMap.clear();
         } else {
             cleanBaseIncrementalValueStore(-1, this.baseIncrementalValueStore);