From 0eaadd92d8478477d922ddf34ccc84f2e25cb9cd Mon Sep 17 00:00:00 2001 From: binlijin Date: Thu, 21 Oct 2021 21:30:19 +0800 Subject: [PATCH] HBASE-26385 Clear CellScanner when replay (#3773) Signed-off-by: Duo Zhang Signed-off-by: Pankaj Kumar --- .../org/apache/hadoop/hbase/regionserver/RSRpcServices.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index 5f99d6cc6af..626e1d08f06 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -2242,6 +2242,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, AdminService.Blockin final ReplicateWALEntryRequest request) throws ServiceException { long before = EnvironmentEdgeManager.currentTime(); CellScanner cells = ((HBaseRpcController) controller).cellScanner(); + ((HBaseRpcController) controller).setCellScanner(null); try { checkOpen(); List entries = request.getEntryList(); @@ -2344,6 +2345,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, AdminService.Blockin requestCount.increment(); List entries = request.getEntryList(); CellScanner cellScanner = ((HBaseRpcController)controller).cellScanner(); + ((HBaseRpcController) controller).setCellScanner(null); regionServer.getRegionServerCoprocessorHost().preReplicateLogEntries(); regionServer.getReplicationSinkService().replicateLogEntries(entries, cellScanner, request.getReplicationClusterId(), request.getSourceBaseNamespaceDirPath(),