Repository: hbase Updated Branches: refs/heads/branch-1 5aeddb305 -> a0b2141a9
HBASE-20146 Addendum Regions are stuck while opening when WAL is disabled Signed-off-by: zhangduo <[email protected]> Signed-off-by: Chia-Ping Tsai <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a0b2141a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a0b2141a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a0b2141a Branch: refs/heads/branch-1 Commit: a0b2141a955369f19ab083725afa282ba31a80a2 Parents: 5aeddb3 Author: Ashish Singhi <[email protected]> Authored: Tue Mar 13 15:31:39 2018 +0530 Committer: zhangduo <[email protected]> Committed: Thu Mar 15 10:17:03 2018 +0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/wal/DisabledWALProvider.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/a0b2141a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/DisabledWALProvider.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/DisabledWALProvider.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/DisabledWALProvider.java index 30ea651..3dc1d5a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/DisabledWALProvider.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/DisabledWALProvider.java @@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.classification.InterfaceAudience; // imports for things that haven't moved from regionserver.wal yet. +import org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl.WriteEntry; import org.apache.hadoop.hbase.regionserver.wal.WALActionsListener; import org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost; import org.apache.hadoop.hbase.regionserver.wal.WALEdit; @@ -162,7 +163,13 @@ class DisabledWALProvider implements WALProvider { @Override public long append(HTableDescriptor htd, HRegionInfo info, WALKey key, WALEdit edits, boolean inMemstore) throws IOException { - key.setWriteEntry(key.getMvcc().begin()); + WriteEntry writeEntry = key.getMvcc().begin(); + if (!edits.isReplay()) { + for (Cell cell : edits.getCells()) { + CellUtil.setSequenceId(cell, writeEntry.getWriteNumber()); + } + } + key.setWriteEntry(writeEntry); if (!this.listeners.isEmpty()) { final long start = System.nanoTime(); long len = 0;
