Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-26385 Clear CellScanner when replay (#3773) 

Signed-off-by: Duo Zhang <zhangduo@apache.org>
Signed-off-by: Pankaj Kumar <pankajkumar@apache.org>
This commit is contained in:
binlijin 2021-10-21 21:30:19 +08:00 committed by Duo Zhang
parent dce45ec16a
commit 0eaadd92d8
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java
View File

@ -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<WALEntry> entries = request.getEntryList();
@ -2344,6 +2345,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, AdminService.Blockin
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(),