You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gx...@apache.org on 2018/09/12 02:51:45 UTC
[2/3] hbase git commit: HBASE-21179 Fix the number of actions in
responseTooSlow log
HBASE-21179 Fix the number of actions in responseTooSlow log
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9de388cf
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9de388cf
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9de388cf
Branch: refs/heads/branch-2.0
Commit: 9de388cf388281bcdbaf69cc12fabe9893be48f2
Parents: 46492be
Author: Guangxu Cheng <gu...@gmail.com>
Authored: Mon Sep 10 20:32:20 2018 +0800
Committer: Guangxu Cheng <gu...@gmail.com>
Committed: Wed Sep 12 10:44:57 2018 +0800
----------------------------------------------------------------------
.../apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/9de388cf/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java
index 4d53720..9de39dd 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java
@@ -2183,6 +2183,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 = r.getRegionActionList()
+ .stream()
+ .mapToInt(ClientProtos.RegionAction::getActionCount)
+ .sum();
+
// Get first set of Actions.
ClientProtos.RegionAction actions = r.getRegionActionList().get(0);
String row = actions.getActionCount() <= 0? "":
@@ -2190,8 +2197,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()) +