commit 0166ffefefe91c9eed59f91101470091126f3220
author Ankit Singhal <ankitsinghal59@gmail.com> Mon Mar 06 15:09:41 2017 +0530
committer Ankit Singhal <ankitsinghal59@gmail.com> Mon Mar 06 15:09:41 2017 +0530
tree 874827def82775753f09ad9c8ba10d5fe64e9be0
parent bf91232dfd1a4f23dc36cb9629d670f66f34af42

Higher memory consumption on RS leading to OOM/abort on immutable index creation with multiple regions on single RS

phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java

diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
index 9ee0054..1b92fdc 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java
@@ -596,6 +596,7 @@
                                     mutations.add(put);
                                 }
                             }
+                        }
                             // Commit in batches based on UPSERT_BATCH_SIZE_ATTRIB in config
                             if (!mutations.isEmpty() && batchSize > 0 &&
                                     mutations.size() % batchSize == 0) {
@@ -609,7 +610,7 @@
                                 commitBatch(region, indexMutations, null, blockingMemStoreSize, null, txState);
                                 indexMutations.clear();
                             }
-                        }
+                        
                         aggregators.aggregate(rowAggregators, result);
                         hasAny = true;
                     }