Repository: hbase Updated Branches: refs/heads/branch-1.4 9573f7629 -> dc8cf112a
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/dc8cf112 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/dc8cf112 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/dc8cf112 Branch: refs/heads/branch-1.4 Commit: dc8cf112a73e8379488158bbc67b9f6292957dc9 Parents: 9573f76 Author: tedyu <[email protected]> Authored: Sat Aug 18 11:48:42 2018 -0700 Committer: tedyu <[email protected]> Committed: Sat Aug 18 11:48:42 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/dc8cf112/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 3464600..705a4bd 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 @@ -7584,8 +7584,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();
