You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2018/08/20 22:32:52 UTC
hbase git commit: HBASE-21042 processor.getRowsToLock() always
assumes there is some row being locked in HRegion#processRowsWithLocks
[Forced Update!]
Repository: hbase
Updated Branches:
refs/heads/branch-1.3 e81832f41 -> b447ccc31 (forced update)
HBASE-21042 processor.getRowsToLock() always assumes there is some row being locked in HRegion#processRowsWithLocks
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/b447ccc3
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/b447ccc3
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/b447ccc3
Branch: refs/heads/branch-1.3
Commit: b447ccc314871f99cf931713a24f5bef6c258aff
Parents: d1b0c32
Author: tedyu <yu...@gmail.com>
Authored: Sat Aug 18 11:48:42 2018 -0700
Committer: Andrew Purtell <ap...@apache.org>
Committed: Mon Aug 20 15:32:47 2018 -0700
----------------------------------------------------------------------
.../main/java/org/apache/hadoop/hbase/regionserver/HRegion.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/b447ccc3/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
index 7d62f4e..26a5958 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
@@ -7372,8 +7372,9 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
// different. Make them all share same code!
if (!mutations.isEmpty() && !walSyncSuccessful) {
LOG.warn("Wal sync failed. Roll back " + mutations.size() +
- " memstore keyvalues for row(s):" + StringUtils.byteToHexString(
- processor.getRowsToLock().iterator().next()) + "...");
+ " memstore keyvalues" + (processor.getRowsToLock().isEmpty() ? "" :
+ (" for row(s):" + StringUtils.byteToHexString(
+ processor.getRowsToLock().iterator().next()) + "...")));
for (Mutation m : mutations) {
for (CellScanner cellScanner = m.cellScanner(); cellScanner.advance();) {
Cell cell = cellScanner.current();