You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2021/10/21 14:11:46 UTC
[hbase] branch branch-2.4 updated: HBASE-26385 Clear CellScanner
when replay (#3773)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new 446630b HBASE-26385 Clear CellScanner when replay (#3773)
446630b is described below
commit 446630b71323d60e0fa5e54616cf9449d299575b
Author: binlijin <bi...@gmail.com>
AuthorDate: Thu Oct 21 21:30:19 2021 +0800
HBASE-26385 Clear CellScanner when replay (#3773)
Signed-off-by: Duo Zhang <zh...@apache.org>
Signed-off-by: Pankaj Kumar <pa...@apache.org>
---
.../main/java/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 a58cfb1..00752ca 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
@@ -2217,6 +2217,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler,
final ReplicateWALEntryRequest request) throws ServiceException {
long before = EnvironmentEdgeManager.currentTime();
CellScanner cells = ((HBaseRpcController) controller).cellScanner();
+ ((HBaseRpcController) controller).setCellScanner(null);
try {
checkOpen();
List<WALEntry> entries = request.getEntryList();
@@ -2319,6 +2320,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler,
requestCount.increment();
List<WALEntry> entries = request.getEntryList();
CellScanner cellScanner = ((HBaseRpcController)controller).cellScanner();
+ ((HBaseRpcController) controller).setCellScanner(null);
regionServer.getRegionServerCoprocessorHost().preReplicateLogEntries();
regionServer.getReplicationSinkService().replicateLogEntries(entries, cellScanner,
request.getReplicationClusterId(), request.getSourceBaseNamespaceDirPath(),