commit 5b2050c49dddef934325208b41d68cdb1e9d8c4b
author Kadir <kozdemir@salesforce.com> Wed Oct 16 12:03:12 2019 -0700
committer Kadir <kozdemir@salesforce.com> Wed Oct 16 12:03:12 2019 -0700
tree caa1f83c8fe536771f630882b351aa0da6e07d56
parent eebccf59a2a19ff2d3b328b113117c7e6685e75e

PHOENIX-5532 Index write failure does not cleanup pendingRows entries

phoenix-core/src/main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java

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 @@
           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(