From ae132007a2d0a2b8e926094720f73e91e5e9ba49 Mon Sep 17 00:00:00 2001 From: Guangxu Cheng Date: Wed, 12 Sep 2018 12:55:47 +0800 Subject: [PATCH] HBASE-21179 Fix the number of actions in responseTooSlow log --- .../org/apache/hadoop/hbase/protobuf/ProtobufUtil.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/protobuf/ProtobufUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/protobuf/ProtobufUtil.java index a76353ba66..e630b98a79 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/protobuf/ProtobufUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/protobuf/ProtobufUtil.java @@ -2976,6 +2976,13 @@ public final class ProtobufUtil { ", row=" + getStringForByteString(r.getGet().getRow()); } else if (m instanceof ClientProtos.MultiRequest) { ClientProtos.MultiRequest r = (ClientProtos.MultiRequest) m; + + // Get the number of Actions + int actionsCount = 0; + for (ClientProtos.RegionAction regionAction : r.getRegionActionList()) { + actionsCount += regionAction.getActionCount(); + } + // Get first set of Actions. ClientProtos.RegionAction actions = r.getRegionActionList().get(0); String row = actions.getActionCount() <= 0? "": @@ -2983,8 +2990,7 @@ public final class ProtobufUtil { actions.getAction(0).getGet().getRow(): actions.getAction(0).getMutation().getRow()); return "region= " + getStringForByteString(actions.getRegion().getValue()) + - ", for " + r.getRegionActionCount() + - " actions and 1st row key=" + row; + ", for " + actionsCount + " action(s) and 1st row key=" + row; } else if (m instanceof ClientProtos.MutateRequest) { ClientProtos.MutateRequest r = (ClientProtos.MutateRequest) m; return "region= " + getStringForByteString(r.getRegion().getValue()) + -- 2.17.1