This is an automated email from the ASF dual-hosted git repository. apurtell pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.1 by this push: new 6805224 HBASE-23207 Log a region open journal (#751) 6805224 is described below commit 6805224124f11a55ec485f5bfc8e4571209e671b Author: Andrew Purtell <apurt...@apache.org> AuthorDate: Wed Oct 23 17:17:06 2019 -0700 HBASE-23207 Log a region open journal (#751) Signed-off-by: Abhishek Singh Chouhan <achou...@apache.org> --- .../main/java/org/apache/hadoop/hbase/regionserver/HRegion.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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 dfe6eb6..28fbf4d 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 @@ -894,6 +894,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi } MonitoredTask status = TaskMonitor.get().createStatus("Initializing region " + this); + status.enableStatusJournal(true); long nextSeqId = -1; try { nextSeqId = initializeRegionInternals(reporter, status); @@ -921,6 +922,10 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi status.abort("Exception during region " + getRegionInfo().getRegionNameAsString() + " initialization."); } + if (LOG.isDebugEnabled()) { + LOG.debug("Region open journal:\n" + status.prettyPrintJournal()); + } + status.cleanup(); } } @@ -1508,7 +1513,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi MonitoredTask status = TaskMonitor.get().createStatus( "Closing region " + this.getRegionInfo().getEncodedName() + (abort ? " due to abort" : "")); - status.enableStatusJournal(false); + status.enableStatusJournal(true); status.setStatus("Waiting for close lock"); try { synchronized (closeLock) {