[phoenix] branch master updated: PHOENIX-5532 Index write failure does not cleanup pendingRows entries

[ka...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kadir pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/master by this push:
     new 5b2050c  PHOENIX-5532 Index write failure does not cleanup pendingRows entries
5b2050c is described below

commit 5b2050c49dddef934325208b41d68cdb1e9d8c4b
Author: Kadir <ko...@salesforce.com>
AuthorDate: Wed Oct 16 12:03:12 2019 -0700

    PHOENIX-5532 Index write failure does not cleanup pendingRows entries
---
 .../main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java
index 77aed76..0402c6f 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java
@@ -793,8 +793,8 @@ public class IndexRegionObserver implements RegionObserver, RegionCoprocessor {
           metricSource.incrementPreIndexUpdateFailures();
           // Remove all locks as they are already unlocked. There is no need to unlock them again later when
           // postBatchMutateIndispensably() is called
-          context.rowLocks.clear();
           removePendingRows(context);
+          context.rowLocks.clear();
           rethrowIndexingException(e);
       }
       throw new RuntimeException(