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()));