From 08c407895aec34bad03fe7a90854e152bc3a811c Mon Sep 17 00:00:00 2001 From: Andrew Purtell Date: Fri, 21 Jun 2019 14:33:49 -0700 Subject: [PATCH] HBASE-22616 responseTooXXX logging for Multi should characterize the component ops --- .../apache/hadoop/hbase/ipc/RpcServer.java | 22 +++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java index a32040c295..7768d5c709 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java @@ -2484,6 +2484,28 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver { } } } + if (param instanceof ClientProtos.MultiRequest) { + int numGets = 0; + int numMutations = 0; + int numServiceCalls = 0; + ClientProtos.MultiRequest multi = (ClientProtos.MultiRequest)param; + for (ClientProtos.RegionAction regionAction : multi.getRegionActionList()) { + for (ClientProtos.Action action: regionAction.getActionList()) { + if (action.hasMutation()) { + numMutations++; + } + if (action.hasGet()) { + numGets++; + } + if (action.hasServiceCall()) { + numServiceCalls++; + } + } + } + responseInfo.put("multi.gets", numGets); + responseInfo.put("multi.mutations", numMutations); + responseInfo.put("multi.servicecalls", numServiceCalls); + } LOG.warn("(response" + tag + "): " + MAPPER.writeValueAsString(responseInfo)); } -- 2.22.0