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

achouhan pushed a commit to branch 4.x
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x by this push:
     new 4215de3  Addendum PHOENIX-6511 Deletes fail in case of failed region 
split
4215de3 is described below

commit 4215de3dc6e8d87a26ffda3bc8b2cf82ea31994a
Author: Abhishek Singh Chouhan <achou...@apache.org>
AuthorDate: Thu Jul 15 12:20:01 2021 -0700

    Addendum PHOENIX-6511 Deletes fail in case of failed region split
---
 .../end2end/UngroupedAggregateRegionObserverSplitFailureIT.java        | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UngroupedAggregateRegionObserverSplitFailureIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UngroupedAggregateRegionObserverSplitFailureIT.java
index 454b632..33614db 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UngroupedAggregateRegionObserverSplitFailureIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UngroupedAggregateRegionObserverSplitFailureIT.java
@@ -33,6 +33,7 @@ import org.apache.hadoop.hbase.TableName;
 import org.apache.hadoop.hbase.coprocessor.ObserverContext;
 import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
 import org.apache.hadoop.hbase.regionserver.HRegion;
+import org.apache.phoenix.compat.hbase.CompatObserverContext;
 import org.apache.phoenix.coprocessor.UngroupedAggregateRegionObserver;
 import org.apache.phoenix.jdbc.PhoenixDriver;
 import org.apache.phoenix.util.PhoenixRuntime;
@@ -88,7 +89,7 @@ public class UngroupedAggregateRegionObserverSplitFailureIT 
extends BaseUniqueNa
                 UngroupedAggregateRegionObserver obs =
                         (UngroupedAggregateRegionObserver) 
region.getCoprocessorHost()
                                 
.findCoprocessor(UngroupedAggregateRegionObserver.class.getName());
-                ObserverContext<RegionCoprocessorEnvironment> ctx = new 
ObserverContext<RegionCoprocessorEnvironment>(null);
+                ObserverContext<RegionCoprocessorEnvironment> ctx = new 
CompatObserverContext<RegionCoprocessorEnvironment>(null);
                 ctx.prepare((RegionCoprocessorEnvironment) 
region.getCoprocessorHost()
                         .findCoprocessorEnvironment(
                             UngroupedAggregateRegionObserver.class.getName()));

Reply via email to