hbase git commit: HBASE-20808 Wrong shutdown order between Chores and ChoreService
Repository: hbase
Updated Branches:
refs/heads/branch-1.4 0d1fffbb4 -> 822c18a03
HBASE-20808 Wrong shutdown order between Chores and ChoreService
Signed-off-by: Reid Chan
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/822c18a0
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/822c18a0
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/822c18a0
Branch: refs/heads/branch-1.4
Commit: 822c18a03ff274a398f6a037445df0d620d276e9
Parents: 0d1fffb
Author: Nihal Jain
Authored: Fri Jul 6 00:42:58 2018 +0530
Committer: Reid Chan
Committed: Sat Jul 7 00:34:17 2018 +0800
--
.../org/apache/hadoop/hbase/master/HMaster.java | 36
.../hbase/regionserver/HRegionServer.java | 21 ++--
2 files changed, 24 insertions(+), 33 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/822c18a0/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index 9dcc3fd..18bfa74 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -50,6 +50,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hbase.ChoreService;
import org.apache.hadoop.hbase.ClusterStatus;
import org.apache.hadoop.hbase.CoordinatedStateException;
import org.apache.hadoop.hbase.CoordinatedStateManager;
@@ -1283,8 +1284,8 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
LOG.error("Failed to stop master jetty server", e);
}
}
-super.stopServiceThreads();
stopChores();
+super.stopServiceThreads();
CleanerChore.shutDownChorePool();
// Wait for all the remaining region servers to report in IFF we were
@@ -1297,10 +1298,6 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
LOG.debug("Stopping service threads");
}
// Clean up and close up shop
-if (this.logCleaner != null) this.logCleaner.cancel(true);
-if (this.hfileCleaner != null) this.hfileCleaner.cancel(true);
-if (this.replicationZKLockCleanerChore != null)
this.replicationZKLockCleanerChore.cancel(true);
-if (this.replicationZKNodeCleanerChore != null)
this.replicationZKNodeCleanerChore.cancel(true);
if (this.quotaManager != null) this.quotaManager.stop();
if (this.activeMasterManager != null) this.activeMasterManager.stop();
if (this.serverManager != null) this.serverManager.stop();
@@ -1341,23 +1338,18 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
}
private void stopChores() {
-if (this.balancerChore != null) {
- this.balancerChore.cancel(true);
-}
-if (this.normalizerChore != null) {
- this.normalizerChore.cancel(true);
-}
-if (this.clusterStatusChore != null) {
- this.clusterStatusChore.cancel(true);
-}
-if (this.catalogJanitorChore != null) {
- this.catalogJanitorChore.cancel(true);
-}
-if (this.clusterStatusPublisherChore != null){
- clusterStatusPublisherChore.cancel(true);
-}
-if (this.periodicDoMetricsChore != null) {
- periodicDoMetricsChore.cancel();
+ChoreService choreService = getChoreService();
+if (choreService != null) {
+ choreService.cancelChore(this.balancerChore);
+ choreService.cancelChore(this.normalizerChore);
+ choreService.cancelChore(this.clusterStatusChore);
+ choreService.cancelChore(this.catalogJanitorChore);
+ choreService.cancelChore(this.clusterStatusPublisherChore);
+ choreService.cancelChore(this.periodicDoMetricsChore);
+ choreService.cancelChore(this.logCleaner);
+ choreService.cancelChore(this.hfileCleaner);
+ choreService.cancelChore(this.replicationZKLockCleanerChore);
+ choreService.cancelChore(this.replicationZKNodeCleanerChore);
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/822c18a0/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
index dd01ea0..962a0e9 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
+++
hbase git commit: HBASE-20808 Wrong shutdown order between Chores and ChoreService
Repository: hbase
Updated Branches:
refs/heads/branch-1 154b77307 -> 77e5668ed
HBASE-20808 Wrong shutdown order between Chores and ChoreService
Signed-off-by: Reid Chan
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/77e5668e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/77e5668e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/77e5668e
Branch: refs/heads/branch-1
Commit: 77e5668ed20b20c8b91128ee819927a26041272d
Parents: 154b773
Author: Nihal Jain
Authored: Fri Jul 6 00:42:58 2018 +0530
Committer: Reid Chan
Committed: Sat Jul 7 00:32:33 2018 +0800
--
.../org/apache/hadoop/hbase/master/HMaster.java | 36
.../hbase/regionserver/HRegionServer.java | 21 ++--
2 files changed, 24 insertions(+), 33 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/77e5668e/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index cfa6aa2..21ec23c 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -51,6 +51,7 @@ import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hbase.ChoreService;
import org.apache.hadoop.hbase.ClusterStatus;
import org.apache.hadoop.hbase.CoordinatedStateException;
import org.apache.hadoop.hbase.CoordinatedStateManager;
@@ -1284,8 +1285,8 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
LOG.error("Failed to stop master jetty server", e);
}
}
-super.stopServiceThreads();
stopChores();
+super.stopServiceThreads();
CleanerChore.shutDownChorePool();
// Wait for all the remaining region servers to report in IFF we were
@@ -1298,10 +1299,6 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
LOG.debug("Stopping service threads");
}
// Clean up and close up shop
-if (this.logCleaner != null) this.logCleaner.cancel(true);
-if (this.hfileCleaner != null) this.hfileCleaner.cancel(true);
-if (this.replicationZKLockCleanerChore != null)
this.replicationZKLockCleanerChore.cancel(true);
-if (this.replicationZKNodeCleanerChore != null)
this.replicationZKNodeCleanerChore.cancel(true);
if (this.quotaManager != null) this.quotaManager.stop();
if (this.activeMasterManager != null) this.activeMasterManager.stop();
if (this.serverManager != null) this.serverManager.stop();
@@ -1355,23 +1352,18 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
}
private void stopChores() {
-if (this.balancerChore != null) {
- this.balancerChore.cancel(true);
-}
-if (this.normalizerChore != null) {
- this.normalizerChore.cancel(true);
-}
-if (this.clusterStatusChore != null) {
- this.clusterStatusChore.cancel(true);
-}
-if (this.catalogJanitorChore != null) {
- this.catalogJanitorChore.cancel(true);
-}
-if (this.clusterStatusPublisherChore != null){
- clusterStatusPublisherChore.cancel(true);
-}
-if (this.periodicDoMetricsChore != null) {
- periodicDoMetricsChore.cancel();
+ChoreService choreService = getChoreService();
+if (choreService != null) {
+ choreService.cancelChore(this.balancerChore);
+ choreService.cancelChore(this.normalizerChore);
+ choreService.cancelChore(this.clusterStatusChore);
+ choreService.cancelChore(this.catalogJanitorChore);
+ choreService.cancelChore(this.clusterStatusPublisherChore);
+ choreService.cancelChore(this.periodicDoMetricsChore);
+ choreService.cancelChore(this.logCleaner);
+ choreService.cancelChore(this.hfileCleaner);
+ choreService.cancelChore(this.replicationZKLockCleanerChore);
+ choreService.cancelChore(this.replicationZKNodeCleanerChore);
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/77e5668e/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
index 8512c2f..6c32643 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
+++
hbase git commit: HBASE-20808 (Addendum) Remove duplicate calls for cancelling of chores
Repository: hbase Updated Branches: refs/heads/branch-2.1 3ed935023 -> 927ac8228 HBASE-20808 (Addendum) Remove duplicate calls for cancelling of chores Signed-off-by: Reid Chan Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/927ac822 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/927ac822 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/927ac822 Branch: refs/heads/branch-2.1 Commit: 927ac8228f0715157eccaa57ef9c85f55547235e Parents: 3ed9350 Author: Nihal Jain Authored: Fri Jul 6 18:27:08 2018 +0530 Committer: Reid Chan Committed: Sat Jul 7 00:21:08 2018 +0800 -- .../java/org/apache/hadoop/hbase/regionserver/HRegionServer.java | 4 1 file changed, 4 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/927ac822/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index 91a5769..c136e92 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -1045,10 +1045,6 @@ public class HRegionServer extends HasThread implements if (this.hMemManager != null) this.hMemManager.stop(); if (this.cacheFlusher != null) this.cacheFlusher.interruptIfNecessary(); if (this.compactSplitThread != null) this.compactSplitThread.interruptIfNecessary(); -if (this.compactionChecker != null) this.compactionChecker.cancel(true); -if (this.healthCheckChore != null) this.healthCheckChore.cancel(true); -if (this.nonceManagerChore != null) this.nonceManagerChore.cancel(true); -if (this.storefileRefresher != null) this.storefileRefresher.cancel(true); sendShutdownInterrupt(); // Stop the quota manager
hbase git commit: HBASE-20808 Wrong shutdown order between Chores and ChoreService
Repository: hbase
Updated Branches:
refs/heads/branch-2.1 a2db3d27f -> 3ed935023
HBASE-20808 Wrong shutdown order between Chores and ChoreService
Signed-off-by: Reid Chan
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/3ed93502
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3ed93502
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3ed93502
Branch: refs/heads/branch-2.1
Commit: 3ed9350233344b9bede4615dd3f817dae5ac23b7
Parents: a2db3d2
Author: Nihal Jain
Authored: Sun Jul 1 13:08:14 2018 +0530
Committer: Reid Chan
Committed: Sat Jul 7 00:20:08 2018 +0800
--
.../org/apache/hadoop/hbase/master/HMaster.java | 40 +---
.../hbase/regionserver/HRegionServer.java | 19 ++
2 files changed, 29 insertions(+), 30 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/3ed93502/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index a5e07ba..f0e6711 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -58,6 +58,7 @@ import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hbase.ChoreService;
import org.apache.hadoop.hbase.ClusterId;
import org.apache.hadoop.hbase.ClusterMetrics;
import org.apache.hadoop.hbase.ClusterMetrics.Option;
@@ -72,7 +73,6 @@ import org.apache.hadoop.hbase.MetaTableAccessor;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.PleaseHoldException;
import org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
-import org.apache.hadoop.hbase.ScheduledChore;
import org.apache.hadoop.hbase.ServerName;
import org.apache.hadoop.hbase.TableDescriptors;
import org.apache.hadoop.hbase.TableName;
@@ -1255,12 +1255,6 @@ public class HMaster extends HRegionServer implements
MasterServices {
}
}
- private void cancelChore(ScheduledChore chore) {
-if (chore != null) {
- chore.cancel();
-}
- }
-
@Override
protected void stopServiceThreads() {
if (masterJettyServer != null) {
@@ -1271,8 +1265,11 @@ public class HMaster extends HRegionServer implements
MasterServices {
LOG.error("Failed to stop master jetty server", e);
}
}
-super.stopServiceThreads();
stopChores();
+if (this.mobCompactThread != null) {
+ this.mobCompactThread.close();
+}
+super.stopServiceThreads();
CleanerChore.shutDownChorePool();
LOG.debug("Stopping service threads");
@@ -1350,21 +1347,20 @@ public class HMaster extends HRegionServer implements
MasterServices {
}
private void stopChores() {
-cancelChore(this.expiredMobFileCleanerChore);
-cancelChore(this.mobCompactChore);
-cancelChore(this.balancerChore);
-cancelChore(this.normalizerChore);
-cancelChore(this.clusterStatusChore);
-cancelChore(this.catalogJanitorChore);
-cancelChore(this.clusterStatusPublisherChore);
-if (this.mobCompactThread != null) {
- this.mobCompactThread.close();
+ChoreService choreService = getChoreService();
+if (choreService != null) {
+ choreService.cancelChore(this.expiredMobFileCleanerChore);
+ choreService.cancelChore(this.mobCompactChore);
+ choreService.cancelChore(this.balancerChore);
+ choreService.cancelChore(this.normalizerChore);
+ choreService.cancelChore(this.clusterStatusChore);
+ choreService.cancelChore(this.catalogJanitorChore);
+ choreService.cancelChore(this.clusterStatusPublisherChore);
+ choreService.cancelChore(this.snapshotQuotaChore);
+ choreService.cancelChore(this.logCleaner);
+ choreService.cancelChore(this.hfileCleaner);
+ choreService.cancelChore(this.replicationBarrierCleaner);
}
-cancelChore(this.clusterStatusPublisherChore);
-cancelChore(this.snapshotQuotaChore);
-cancelChore(this.logCleaner);
-cancelChore(this.hfileCleaner);
-cancelChore(this.replicationBarrierCleaner);
}
/**
http://git-wip-us.apache.org/repos/asf/hbase/blob/3ed93502/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
index 39b006c..91a5769
hbase git commit: HBASE-20808 (Addendum) Remove duplicate calls for cancelling of chores
Repository: hbase Updated Branches: refs/heads/branch-2 473c71edb -> 1da2fa3ba HBASE-20808 (Addendum) Remove duplicate calls for cancelling of chores Signed-off-by: Reid Chan Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1da2fa3b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1da2fa3b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1da2fa3b Branch: refs/heads/branch-2 Commit: 1da2fa3baa6ad99aceb50218631f9fb4f05124e8 Parents: 473c71e Author: Nihal Jain Authored: Fri Jul 6 18:27:08 2018 +0530 Committer: Reid Chan Committed: Sat Jul 7 00:18:22 2018 +0800 -- .../java/org/apache/hadoop/hbase/regionserver/HRegionServer.java | 4 1 file changed, 4 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/1da2fa3b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index 91a5769..c136e92 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -1045,10 +1045,6 @@ public class HRegionServer extends HasThread implements if (this.hMemManager != null) this.hMemManager.stop(); if (this.cacheFlusher != null) this.cacheFlusher.interruptIfNecessary(); if (this.compactSplitThread != null) this.compactSplitThread.interruptIfNecessary(); -if (this.compactionChecker != null) this.compactionChecker.cancel(true); -if (this.healthCheckChore != null) this.healthCheckChore.cancel(true); -if (this.nonceManagerChore != null) this.nonceManagerChore.cancel(true); -if (this.storefileRefresher != null) this.storefileRefresher.cancel(true); sendShutdownInterrupt(); // Stop the quota manager
hbase git commit: HBASE-20808 (Addendum) Remove duplicate calls for cancelling of chores
Repository: hbase Updated Branches: refs/heads/master 1ade4d2f4 -> 361be5334 HBASE-20808 (Addendum) Remove duplicate calls for cancelling of chores Signed-off-by: Reid Chan Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/361be533 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/361be533 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/361be533 Branch: refs/heads/master Commit: 361be533445e06ce477db9ac07a809e11f813ed4 Parents: 1ade4d2 Author: Nihal Jain Authored: Fri Jul 6 18:27:08 2018 +0530 Committer: Reid Chan Committed: Sat Jul 7 00:17:10 2018 +0800 -- .../java/org/apache/hadoop/hbase/regionserver/HRegionServer.java | 4 1 file changed, 4 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/361be533/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index 3fe386d..a43339b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -1048,10 +1048,6 @@ public class HRegionServer extends HasThread implements if (this.hMemManager != null) this.hMemManager.stop(); if (this.cacheFlusher != null) this.cacheFlusher.interruptIfNecessary(); if (this.compactSplitThread != null) this.compactSplitThread.interruptIfNecessary(); -if (this.compactionChecker != null) this.compactionChecker.cancel(true); -if (this.healthCheckChore != null) this.healthCheckChore.cancel(true); -if (this.nonceManagerChore != null) this.nonceManagerChore.cancel(true); -if (this.storefileRefresher != null) this.storefileRefresher.cancel(true); sendShutdownInterrupt(); // Stop the snapshot and other procedure handlers, forcefully killing all running tasks
[16/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html index 992b9b2..323b37f 100644 --- a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html @@ -273,12 +273,12 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.io.hfile.BlockType.BlockCategory -org.apache.hadoop.hbase.io.hfile.Cacheable.MemoryType +org.apache.hadoop.hbase.io.hfile.CacheConfig.ExternalBlockCaches org.apache.hadoop.hbase.io.hfile.HFileBlock.Writer.State -org.apache.hadoop.hbase.io.hfile.BlockPriority +org.apache.hadoop.hbase.io.hfile.Cacheable.MemoryType org.apache.hadoop.hbase.io.hfile.BlockType -org.apache.hadoop.hbase.io.hfile.CacheConfig.ExternalBlockCaches +org.apache.hadoop.hbase.io.hfile.BlockType.BlockCategory +org.apache.hadoop.hbase.io.hfile.BlockPriority http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html index 928ae20..6a2998c 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html @@ -349,9 +349,9 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) +org.apache.hadoop.hbase.ipc.CallEvent.Type org.apache.hadoop.hbase.ipc.BufferCallBeforeInitHandler.BufferCallAction org.apache.hadoop.hbase.ipc.MetricsHBaseServerSourceFactoryImpl.SourceStorage -org.apache.hadoop.hbase.ipc.CallEvent.Type http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html index 2e21581..f930505 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html @@ -293,10 +293,10 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.mapreduce.TableSplit.Version org.apache.hadoop.hbase.mapreduce.SyncTable.SyncMapper.Counter -org.apache.hadoop.hbase.mapreduce.RowCounter.RowCounterMapper.Counters org.apache.hadoop.hbase.mapreduce.CellCounter.CellCounterMapper.Counters +org.apache.hadoop.hbase.mapreduce.RowCounter.RowCounterMapper.Counters +org.apache.hadoop.hbase.mapreduce.TableSplit.Version http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html b/devapidocs/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html index 278ee31..a9c669b 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html +++ b/devapidocs/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html @@ -136,7 +136,7 @@ -public static class HMaster.MasterStoppedException +public static class HMaster.MasterStoppedException extends DoNotRetryIOException See Also: @@ -205,7 +205,7 @@ extends MasterStoppedException -MasterStoppedException() +MasterStoppedException()
[14/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/master/balancer/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/balancer/package-tree.html b/devapidocs/org/apache/hadoop/hbase/master/balancer/package-tree.html index abd92a9..1799704 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/balancer/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/master/balancer/package-tree.html @@ -198,8 +198,8 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.LocalityType org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.Action.Type +org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer.Cluster.LocalityType http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/master/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/package-tree.html b/devapidocs/org/apache/hadoop/hbase/master/package-tree.html index f60d2d7..13c7ae9 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/master/package-tree.html @@ -348,8 +348,8 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.master.MetricsMasterSourceFactoryImpl.FactoryStorage org.apache.hadoop.hbase.master.MasterRpcServices.BalanceSwitchMode +org.apache.hadoop.hbase.master.MetricsMasterSourceFactoryImpl.FactoryStorage org.apache.hadoop.hbase.master.RegionState.State org.apache.hadoop.hbase.master.SplitLogManager.TerminationStatus org.apache.hadoop.hbase.master.SplitLogManager.ResubmitDirective http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html index 7a808ff..84fce5c 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/package-tree.html @@ -217,9 +217,9 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface.PeerOperationType +org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType org.apache.hadoop.hbase.master.procedure.MetaProcedureInterface.MetaOperationType org.apache.hadoop.hbase.master.procedure.ServerProcedureInterface.ServerOperationType -org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/monitoring/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/monitoring/package-tree.html b/devapidocs/org/apache/hadoop/hbase/monitoring/package-tree.html index 3e1ea7f..9eb46aa 100644 --- a/devapidocs/org/apache/hadoop/hbase/monitoring/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/monitoring/package-tree.html @@ -125,8 +125,8 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true;
[11/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html
index 18136bc9..a5d418c 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html
@@ -66,21 +66,21 @@
058import
org.apache.commons.lang3.StringUtils;
059import
org.apache.hadoop.conf.Configuration;
060import org.apache.hadoop.fs.Path;
-061import
org.apache.hadoop.hbase.ClusterId;
-062import
org.apache.hadoop.hbase.ClusterMetrics;
-063import
org.apache.hadoop.hbase.ClusterMetrics.Option;
-064import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-065import
org.apache.hadoop.hbase.DoNotRetryIOException;
-066import
org.apache.hadoop.hbase.HBaseIOException;
-067import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
-068import
org.apache.hadoop.hbase.HConstants;
-069import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
-070import
org.apache.hadoop.hbase.MasterNotRunningException;
-071import
org.apache.hadoop.hbase.MetaTableAccessor;
-072import
org.apache.hadoop.hbase.NamespaceDescriptor;
-073import
org.apache.hadoop.hbase.PleaseHoldException;
-074import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
-075import
org.apache.hadoop.hbase.ScheduledChore;
+061import
org.apache.hadoop.hbase.ChoreService;
+062import
org.apache.hadoop.hbase.ClusterId;
+063import
org.apache.hadoop.hbase.ClusterMetrics;
+064import
org.apache.hadoop.hbase.ClusterMetrics.Option;
+065import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
+066import
org.apache.hadoop.hbase.DoNotRetryIOException;
+067import
org.apache.hadoop.hbase.HBaseIOException;
+068import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
+069import
org.apache.hadoop.hbase.HConstants;
+070import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
+071import
org.apache.hadoop.hbase.MasterNotRunningException;
+072import
org.apache.hadoop.hbase.MetaTableAccessor;
+073import
org.apache.hadoop.hbase.NamespaceDescriptor;
+074import
org.apache.hadoop.hbase.PleaseHoldException;
+075import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
076import
org.apache.hadoop.hbase.ServerName;
077import
org.apache.hadoop.hbase.TableDescriptors;
078import
org.apache.hadoop.hbase.TableName;
@@ -1277,2505 +1277,2501 @@
1269}
1270 }
1271
-1272 private void
cancelChore(ScheduledChore chore) {
-1273if (chore != null) {
-1274 chore.cancel();
-1275}
-1276 }
-1277
-1278 @Override
-1279 protected void stopServiceThreads()
{
-1280if (masterJettyServer != null) {
-1281 LOG.info("Stopping master jetty
server");
-1282 try {
-1283masterJettyServer.stop();
-1284 } catch (Exception e) {
-1285LOG.error("Failed to stop master
jetty server", e);
-1286 }
-1287}
-1288super.stopServiceThreads();
-1289stopChores();
-1290CleanerChore.shutDownChorePool();
-1291
-1292LOG.debug("Stopping service
threads");
-1293
-1294if (this.quotaManager != null) {
-1295 this.quotaManager.stop();
-1296}
-1297
-1298if (this.activeMasterManager !=
null) {
-1299 this.activeMasterManager.stop();
+1272 @Override
+1273 protected void stopServiceThreads()
{
+1274if (masterJettyServer != null) {
+1275 LOG.info("Stopping master jetty
server");
+1276 try {
+1277masterJettyServer.stop();
+1278 } catch (Exception e) {
+1279LOG.error("Failed to stop master
jetty server", e);
+1280 }
+1281}
+1282stopChores();
+1283if (this.mobCompactThread != null)
{
+1284 this.mobCompactThread.close();
+1285}
+1286super.stopServiceThreads();
+1287CleanerChore.shutDownChorePool();
+1288
+1289LOG.debug("Stopping service
threads");
+1290
+1291if (this.quotaManager != null) {
+1292 this.quotaManager.stop();
+1293}
+1294
+1295if (this.activeMasterManager !=
null) {
+1296 this.activeMasterManager.stop();
+1297}
+1298if (this.serverManager != null) {
+1299 this.serverManager.stop();
1300}
-1301if (this.serverManager != null) {
-1302 this.serverManager.stop();
+1301if (this.assignmentManager != null)
{
+1302 this.assignmentManager.stop();
1303}
-1304if (this.assignmentManager != null)
{
-1305 this.assignmentManager.stop();
-1306}
-1307
-1308stopProcedureExecutor();
-1309
-1310if (this.walManager != null) {
-1311 this.walManager.stop();
+1304
+1305stopProcedureExecutor();
+1306
+1307if (this.walManager != null) {
+1308 this.walManager.stop();
+1309}
+1310if
[08/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
index 18136bc9..a5d418c 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.TableDescriptorGetter.html
@@ -66,21 +66,21 @@
058import
org.apache.commons.lang3.StringUtils;
059import
org.apache.hadoop.conf.Configuration;
060import org.apache.hadoop.fs.Path;
-061import
org.apache.hadoop.hbase.ClusterId;
-062import
org.apache.hadoop.hbase.ClusterMetrics;
-063import
org.apache.hadoop.hbase.ClusterMetrics.Option;
-064import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-065import
org.apache.hadoop.hbase.DoNotRetryIOException;
-066import
org.apache.hadoop.hbase.HBaseIOException;
-067import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
-068import
org.apache.hadoop.hbase.HConstants;
-069import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
-070import
org.apache.hadoop.hbase.MasterNotRunningException;
-071import
org.apache.hadoop.hbase.MetaTableAccessor;
-072import
org.apache.hadoop.hbase.NamespaceDescriptor;
-073import
org.apache.hadoop.hbase.PleaseHoldException;
-074import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
-075import
org.apache.hadoop.hbase.ScheduledChore;
+061import
org.apache.hadoop.hbase.ChoreService;
+062import
org.apache.hadoop.hbase.ClusterId;
+063import
org.apache.hadoop.hbase.ClusterMetrics;
+064import
org.apache.hadoop.hbase.ClusterMetrics.Option;
+065import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
+066import
org.apache.hadoop.hbase.DoNotRetryIOException;
+067import
org.apache.hadoop.hbase.HBaseIOException;
+068import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
+069import
org.apache.hadoop.hbase.HConstants;
+070import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
+071import
org.apache.hadoop.hbase.MasterNotRunningException;
+072import
org.apache.hadoop.hbase.MetaTableAccessor;
+073import
org.apache.hadoop.hbase.NamespaceDescriptor;
+074import
org.apache.hadoop.hbase.PleaseHoldException;
+075import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
076import
org.apache.hadoop.hbase.ServerName;
077import
org.apache.hadoop.hbase.TableDescriptors;
078import
org.apache.hadoop.hbase.TableName;
@@ -1277,2505 +1277,2501 @@
1269}
1270 }
1271
-1272 private void
cancelChore(ScheduledChore chore) {
-1273if (chore != null) {
-1274 chore.cancel();
-1275}
-1276 }
-1277
-1278 @Override
-1279 protected void stopServiceThreads()
{
-1280if (masterJettyServer != null) {
-1281 LOG.info("Stopping master jetty
server");
-1282 try {
-1283masterJettyServer.stop();
-1284 } catch (Exception e) {
-1285LOG.error("Failed to stop master
jetty server", e);
-1286 }
-1287}
-1288super.stopServiceThreads();
-1289stopChores();
-1290CleanerChore.shutDownChorePool();
-1291
-1292LOG.debug("Stopping service
threads");
-1293
-1294if (this.quotaManager != null) {
-1295 this.quotaManager.stop();
-1296}
-1297
-1298if (this.activeMasterManager !=
null) {
-1299 this.activeMasterManager.stop();
+1272 @Override
+1273 protected void stopServiceThreads()
{
+1274if (masterJettyServer != null) {
+1275 LOG.info("Stopping master jetty
server");
+1276 try {
+1277masterJettyServer.stop();
+1278 } catch (Exception e) {
+1279LOG.error("Failed to stop master
jetty server", e);
+1280 }
+1281}
+1282stopChores();
+1283if (this.mobCompactThread != null)
{
+1284 this.mobCompactThread.close();
+1285}
+1286super.stopServiceThreads();
+1287CleanerChore.shutDownChorePool();
+1288
+1289LOG.debug("Stopping service
threads");
+1290
+1291if (this.quotaManager != null) {
+1292 this.quotaManager.stop();
+1293}
+1294
+1295if (this.activeMasterManager !=
null) {
+1296 this.activeMasterManager.stop();
+1297}
+1298if (this.serverManager != null) {
+1299 this.serverManager.stop();
1300}
-1301if (this.serverManager != null) {
-1302 this.serverManager.stop();
+1301if (this.assignmentManager != null)
{
+1302 this.assignmentManager.stop();
1303}
-1304if (this.assignmentManager != null)
{
-1305 this.assignmentManager.stop();
-1306}
-1307
-1308stopProcedureExecutor();
-1309
-1310if (this.walManager != null) {
-1311 this.walManager.stop();
+1304
+1305stopProcedureExecutor();
+1306
+1307if (this.walManager != null) {
+1308 this.walManager.stop();
+1309}
+1310if
[07/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
--
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
index 18136bc9..a5d418c 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html
@@ -66,21 +66,21 @@
058import
org.apache.commons.lang3.StringUtils;
059import
org.apache.hadoop.conf.Configuration;
060import org.apache.hadoop.fs.Path;
-061import
org.apache.hadoop.hbase.ClusterId;
-062import
org.apache.hadoop.hbase.ClusterMetrics;
-063import
org.apache.hadoop.hbase.ClusterMetrics.Option;
-064import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-065import
org.apache.hadoop.hbase.DoNotRetryIOException;
-066import
org.apache.hadoop.hbase.HBaseIOException;
-067import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
-068import
org.apache.hadoop.hbase.HConstants;
-069import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
-070import
org.apache.hadoop.hbase.MasterNotRunningException;
-071import
org.apache.hadoop.hbase.MetaTableAccessor;
-072import
org.apache.hadoop.hbase.NamespaceDescriptor;
-073import
org.apache.hadoop.hbase.PleaseHoldException;
-074import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
-075import
org.apache.hadoop.hbase.ScheduledChore;
+061import
org.apache.hadoop.hbase.ChoreService;
+062import
org.apache.hadoop.hbase.ClusterId;
+063import
org.apache.hadoop.hbase.ClusterMetrics;
+064import
org.apache.hadoop.hbase.ClusterMetrics.Option;
+065import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
+066import
org.apache.hadoop.hbase.DoNotRetryIOException;
+067import
org.apache.hadoop.hbase.HBaseIOException;
+068import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
+069import
org.apache.hadoop.hbase.HConstants;
+070import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
+071import
org.apache.hadoop.hbase.MasterNotRunningException;
+072import
org.apache.hadoop.hbase.MetaTableAccessor;
+073import
org.apache.hadoop.hbase.NamespaceDescriptor;
+074import
org.apache.hadoop.hbase.PleaseHoldException;
+075import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
076import
org.apache.hadoop.hbase.ServerName;
077import
org.apache.hadoop.hbase.TableDescriptors;
078import
org.apache.hadoop.hbase.TableName;
@@ -1277,2505 +1277,2501 @@
1269}
1270 }
1271
-1272 private void
cancelChore(ScheduledChore chore) {
-1273if (chore != null) {
-1274 chore.cancel();
-1275}
-1276 }
-1277
-1278 @Override
-1279 protected void stopServiceThreads()
{
-1280if (masterJettyServer != null) {
-1281 LOG.info("Stopping master jetty
server");
-1282 try {
-1283masterJettyServer.stop();
-1284 } catch (Exception e) {
-1285LOG.error("Failed to stop master
jetty server", e);
-1286 }
-1287}
-1288super.stopServiceThreads();
-1289stopChores();
-1290CleanerChore.shutDownChorePool();
-1291
-1292LOG.debug("Stopping service
threads");
-1293
-1294if (this.quotaManager != null) {
-1295 this.quotaManager.stop();
-1296}
-1297
-1298if (this.activeMasterManager !=
null) {
-1299 this.activeMasterManager.stop();
+1272 @Override
+1273 protected void stopServiceThreads()
{
+1274if (masterJettyServer != null) {
+1275 LOG.info("Stopping master jetty
server");
+1276 try {
+1277masterJettyServer.stop();
+1278 } catch (Exception e) {
+1279LOG.error("Failed to stop master
jetty server", e);
+1280 }
+1281}
+1282stopChores();
+1283if (this.mobCompactThread != null)
{
+1284 this.mobCompactThread.close();
+1285}
+1286super.stopServiceThreads();
+1287CleanerChore.shutDownChorePool();
+1288
+1289LOG.debug("Stopping service
threads");
+1290
+1291if (this.quotaManager != null) {
+1292 this.quotaManager.stop();
+1293}
+1294
+1295if (this.activeMasterManager !=
null) {
+1296 this.activeMasterManager.stop();
+1297}
+1298if (this.serverManager != null) {
+1299 this.serverManager.stop();
1300}
-1301if (this.serverManager != null) {
-1302 this.serverManager.stop();
+1301if (this.assignmentManager != null)
{
+1302 this.assignmentManager.stop();
1303}
-1304if (this.assignmentManager != null)
{
-1305 this.assignmentManager.stop();
-1306}
-1307
-1308stopProcedureExecutor();
-1309
-1310if (this.walManager != null) {
-1311 this.walManager.stop();
+1304
+1305stopProcedureExecutor();
+1306
+1307if (this.walManager != null) {
+1308 this.walManager.stop();
+1309}
+1310if (this.fileSystemManager != null)
{
+1311 this.fileSystemManager.stop();
1312}
-1313if (this.fileSystemManager
[17/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b. Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/f6b26c52 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/f6b26c52 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/f6b26c52 Branch: refs/heads/asf-site Commit: f6b26c52ebee79835c85716835da3e291939e9b6 Parents: 6b0c5ee Author: jenkins Authored: Fri Jul 6 14:48:56 2018 + Committer: jenkins Committed: Fri Jul 6 14:48:56 2018 + -- acid-semantics.html |4 +- apache_hbase_reference_guide.pdf|4 +- book.html |2 +- bulk-loads.html |4 +- checkstyle-aggregate.html | 392 +- checkstyle.rss |4 +- coc.html|4 +- dependencies.html |4 +- dependency-convergence.html |4 +- dependency-info.html|4 +- dependency-management.html |4 +- devapidocs/constant-values.html |6 +- devapidocs/index-all.html |2 - .../hadoop/hbase/backup/package-tree.html |4 +- .../hadoop/hbase/class-use/ScheduledChore.html | 13 - .../hadoop/hbase/client/package-tree.html | 22 +- .../hadoop/hbase/coprocessor/package-tree.html |2 +- .../hadoop/hbase/filter/package-tree.html | 10 +- .../hadoop/hbase/io/hfile/package-tree.html |8 +- .../apache/hadoop/hbase/ipc/package-tree.html |2 +- .../hadoop/hbase/mapreduce/package-tree.html|4 +- .../master/HMaster.MasterStoppedException.html |4 +- .../master/HMaster.TableDescriptorGetter.html |4 +- .../org/apache/hadoop/hbase/master/HMaster.html | 623 ++- .../hbase/master/balancer/package-tree.html |2 +- .../hadoop/hbase/master/package-tree.html |2 +- .../hbase/master/procedure/package-tree.html|2 +- .../hadoop/hbase/monitoring/package-tree.html |2 +- .../org/apache/hadoop/hbase/package-tree.html | 14 +- .../hadoop/hbase/procedure2/package-tree.html |4 +- .../hadoop/hbase/quotas/package-tree.html |8 +- .../HRegionServer.MovedRegionInfo.html | 16 +- .../HRegionServer.MovedRegionsCleaner.html | 16 +- .../hbase/regionserver/HRegionServer.html | 202 +- .../hadoop/hbase/regionserver/package-tree.html | 18 +- .../hbase/regionserver/wal/package-tree.html|2 +- .../replication/regionserver/package-tree.html |2 +- .../hadoop/hbase/rest/model/package-tree.html |2 +- .../hbase/security/access/package-tree.html |2 +- .../hadoop/hbase/security/package-tree.html |2 +- .../hadoop/hbase/thrift/package-tree.html |2 +- .../apache/hadoop/hbase/util/package-tree.html | 10 +- .../org/apache/hadoop/hbase/Version.html|6 +- .../master/HMaster.InitializationMonitor.html | 4912 +- .../master/HMaster.MasterStoppedException.html | 4912 +- .../hbase/master/HMaster.RedirectServlet.html | 4912 +- .../master/HMaster.TableDescriptorGetter.html | 4912 +- .../org/apache/hadoop/hbase/master/HMaster.html | 4912 +- .../HRegionServer.CompactionChecker.html| 2719 +- .../HRegionServer.MovedRegionInfo.html | 2719 +- .../HRegionServer.MovedRegionsCleaner.html | 2719 +- .../HRegionServer.PeriodicMemStoreFlusher.html | 2719 +- .../hbase/regionserver/HRegionServer.html | 2719 +- downloads.html |4 +- export_control.html |4 +- index.html |4 +- integration.html|4 +- issue-tracking.html |4 +- license.html|4 +- mail-lists.html |4 +- metrics.html|4 +- old_news.html |4 +- plugin-management.html |4 +- plugins.html|4 +- poweredbyhbase.html |4 +- project-info.html |4 +- project-reports.html|4 +- project-summary.html|4 +- pseudo-distributed.html |4 +- replication.html|4 +- resources.html |4 +- source-repository.html |4 +-
[13/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html index 6f1a7b9..c3405f9 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html @@ -2430,7 +2430,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j movedRegions -protectedhttps://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Maphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,HRegionServer.MovedRegionInfo movedRegions +protectedhttps://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Maphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,HRegionServer.MovedRegionInfo movedRegions @@ -2439,7 +2439,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j TIMEOUT_REGION_MOVED -private static finalint TIMEOUT_REGION_MOVED +private static finalint TIMEOUT_REGION_MOVED See Also: Constant Field Values @@ -3512,7 +3512,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j getReplicationSourceService -publicReplicationSourceServicegetReplicationSourceService() +publicReplicationSourceServicegetReplicationSourceService() Specified by: getReplicationSourceServicein interfaceRegionServerServices @@ -3528,7 +3528,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j getReplicationSinkService -publicReplicationSinkServicegetReplicationSinkService() +publicReplicationSinkServicegetReplicationSinkService() Returns: Return the object that implements the replication sink executorService. @@ -3541,7 +3541,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j createRegionServerStatusStub -protectedServerNamecreateRegionServerStatusStub() +protectedServerNamecreateRegionServerStatusStub() Get the current master from ZooKeeper and open the RPC connection to it. To get a fresh connection, the current rssStub must be null. Method will block until a master is available. You can break from this @@ -3558,7 +3558,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j createRegionServerStatusStub -protectedServerNamecreateRegionServerStatusStub(booleanrefresh) +protectedServerNamecreateRegionServerStatusStub(booleanrefresh) Get the current master from ZooKeeper and open the RPC connection to it. To get a fresh connection, the current rssStub must be null. Method will block until a master is available. You can break from this block by requesting the server stop. @@ -3576,7 +3576,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j keepLooping -privatebooleankeepLooping() +privatebooleankeepLooping() Returns: True if we should break loop because cluster is going down or @@ -3590,7 +3590,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j reportForDuty -privateorg.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponsereportForDuty() +privateorg.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponsereportForDuty() throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -3604,7 +3604,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j getLastSequenceId -publicorg.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.RegionStoreSequenceIdsgetLastSequenceId(byte[]encodedRegionName) +publicorg.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.RegionStoreSequenceIdsgetLastSequenceId(byte[]encodedRegionName) Specified by: getLastSequenceIdin interfaceLastSequenceId @@ -3622,7 +3622,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j closeAllRegions -protectedvoidcloseAllRegions(booleanabort) +protectedvoidcloseAllRegions(booleanabort) Closes all regions. Called on our way out. Assumes that its not possible for new regions to be added to onlineRegions while this method runs. @@ -3634,7 +3634,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j closeMetaTableRegions -voidcloseMetaTableRegions(booleanabort) +voidcloseMetaTableRegions(booleanabort) Close meta region if we carry it Parameters: @@
[15/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
b/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
index e51..df966b8 100644
--- a/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
+++ b/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":9,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":9,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":9,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":9,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i109"
:10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":10,"i121":10,"i122":9,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":10,"i135":9,"i136":10,"i137":10,"i138":10,"i139":10,"i140":10,"i141":10,"i142":10,"i143":10,"i144":10,"i145":10,"i146":10,"i147":10,"i148":10,"i149":10,"i150":10,"i151":10,"i152":10,"i153":10,"i154":10,"i155":10,"i156":10,"i157":10,"i158":10,"i159":10,"i160":10,"i161":10,"i162":10,"i163":10,"i164":10,"i165":10,"i166":10,"i167":10,"i168":10,"i169":10,"i170":10,"i171":10,"i172":10,"i173":9};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":9,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":9,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":9,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":9,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i109"
:10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":10,"i121":9,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":9,"i135":10,"i136":10,"i137":10,"i138":10,"i139":10,"i140":10,"i141":10,"i142":10,"i143":10,"i144":10,"i145":10,"i146":10,"i147":10,"i148":10,"i149":10,"i150":10,"i151":10,"i152":10,"i153":10,"i154":10,"i155":10,"i156":10,"i157":10,"i158":10,"i159":10,"i160":10,"i161":10,"i162":10,"i163":10,"i164":10,"i165":10,"i166":10,"i167":10,"i168":10,"i169":10,"i170":10,"i171":10,"i172":9};
var tabs = {65535:["t0","All Methods"],1:["t1","Static
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -561,92 +561,88 @@ implements
-private void
-cancelChore(ScheduledChorechore)
-
-
protected boolean
canCreateBaseZNode()
-
+
protected boolean
canUpdateTableDescriptor()
-
+
private void
checkClassLoading(org.apache.hadoop.conf.Configurationconf,
TableDescriptorhtd)
-
+
private void
checkCompactionPolicy(org.apache.hadoop.conf.Configurationconf,
TableDescriptorhtd)
-
+
private void
checkCompression(ColumnFamilyDescriptorhcd)
-
+
private void
checkCompression(TableDescriptorhtd)
-
+
private void
checkEncryption(org.apache.hadoop.conf.Configurationconf,
ColumnFamilyDescriptorhcd)
-
+
private void
checkEncryption(org.apache.hadoop.conf.Configurationconf,
TableDescriptorhtd)
-
+
void
checkIfShouldMoveSystemRegionAsync()
Called when a new RegionServer is added to the
cluster.
-
+
(package private) void
checkInitialized()
-
+
private void
checkReplicationScope(ColumnFamilyDescriptorhcd)
-
[03/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html
index 7986879..38c8284 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html
@@ -2444,1375 +2444,1378 @@
2436 */
2437 protected void stopServiceThreads()
{
2438// clean up the scheduled chores
-2439if (this.choreService != null)
choreService.shutdown();
-2440if (this.nonceManagerChore != null)
nonceManagerChore.cancel(true);
-2441if (this.compactionChecker != null)
compactionChecker.cancel(true);
-2442if (this.periodicFlusher != null)
periodicFlusher.cancel(true);
-2443if (this.healthCheckChore != null)
healthCheckChore.cancel(true);
-2444if (this.storefileRefresher != null)
storefileRefresher.cancel(true);
-2445if (this.movedRegionsCleaner !=
null) movedRegionsCleaner.cancel(true);
-2446if (this.fsUtilizationChore != null)
fsUtilizationChore.cancel(true);
-2447
-2448if (this.cacheFlusher != null) {
-2449 this.cacheFlusher.join();
-2450}
-2451
-2452if (this.spanReceiverHost != null)
{
-2453
this.spanReceiverHost.closeReceivers();
-2454}
-2455if (this.walRoller != null) {
-2456 this.walRoller.close();
+2439if (this.choreService != null) {
+2440
choreService.cancelChore(nonceManagerChore);
+2441
choreService.cancelChore(compactionChecker);
+2442
choreService.cancelChore(periodicFlusher);
+2443
choreService.cancelChore(healthCheckChore);
+2444
choreService.cancelChore(storefileRefresher);
+2445
choreService.cancelChore(movedRegionsCleaner);
+2446
choreService.cancelChore(fsUtilizationChore);
+2447 // clean up the remaining
scheduled chores (in case we missed out any)
+2448 choreService.shutdown();
+2449}
+2450
+2451if (this.cacheFlusher != null) {
+2452 this.cacheFlusher.join();
+2453}
+2454
+2455if (this.spanReceiverHost != null)
{
+2456
this.spanReceiverHost.closeReceivers();
2457}
-2458if (this.compactSplitThread != null)
{
-2459 this.compactSplitThread.join();
+2458if (this.walRoller != null) {
+2459 this.walRoller.close();
2460}
-2461if (this.executorService != null)
this.executorService.shutdown();
-2462if (this.replicationSourceHandler !=
null
-2463this.replicationSourceHandler ==
this.replicationSinkHandler) {
-2464
this.replicationSourceHandler.stopReplicationService();
-2465} else {
-2466 if (this.replicationSourceHandler
!= null) {
-2467
this.replicationSourceHandler.stopReplicationService();
-2468 }
-2469 if (this.replicationSinkHandler !=
null) {
-2470
this.replicationSinkHandler.stopReplicationService();
+2461if (this.compactSplitThread != null)
{
+2462 this.compactSplitThread.join();
+2463}
+2464if (this.executorService != null)
this.executorService.shutdown();
+2465if (this.replicationSourceHandler !=
null
+2466this.replicationSourceHandler ==
this.replicationSinkHandler) {
+2467
this.replicationSourceHandler.stopReplicationService();
+2468} else {
+2469 if (this.replicationSourceHandler
!= null) {
+2470
this.replicationSourceHandler.stopReplicationService();
2471 }
-2472}
-2473 }
-2474
-2475 /**
-2476 * @return Return the object that
implements the replication
-2477 * source executorService.
-2478 */
-2479 @Override
-2480 public ReplicationSourceService
getReplicationSourceService() {
-2481return replicationSourceHandler;
-2482 }
-2483
-2484 /**
-2485 * @return Return the object that
implements the replication sink executorService.
-2486 */
-2487 public ReplicationSinkService
getReplicationSinkService() {
-2488return replicationSinkHandler;
-2489 }
-2490
-2491 /**
-2492 * Get the current master from
ZooKeeper and open the RPC connection to it.
-2493 * To get a fresh connection, the
current rssStub must be null.
-2494 * Method will block until a master is
available. You can break from this
-2495 * block by requesting the server
stop.
-2496 *
-2497 * @return master + port, or null if
server has been stopped
-2498 */
-2499 @VisibleForTesting
-2500 protected synchronized ServerName
createRegionServerStatusStub() {
-2501// Create RS stub without refreshing
the master node from ZK, use cached data
-2502return
createRegionServerStatusStub(false);
-2503 }
-2504
-2505 /**
-2506 * Get the current
[10/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html
index 18136bc9..a5d418c 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.MasterStoppedException.html
@@ -66,21 +66,21 @@
058import
org.apache.commons.lang3.StringUtils;
059import
org.apache.hadoop.conf.Configuration;
060import org.apache.hadoop.fs.Path;
-061import
org.apache.hadoop.hbase.ClusterId;
-062import
org.apache.hadoop.hbase.ClusterMetrics;
-063import
org.apache.hadoop.hbase.ClusterMetrics.Option;
-064import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-065import
org.apache.hadoop.hbase.DoNotRetryIOException;
-066import
org.apache.hadoop.hbase.HBaseIOException;
-067import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
-068import
org.apache.hadoop.hbase.HConstants;
-069import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
-070import
org.apache.hadoop.hbase.MasterNotRunningException;
-071import
org.apache.hadoop.hbase.MetaTableAccessor;
-072import
org.apache.hadoop.hbase.NamespaceDescriptor;
-073import
org.apache.hadoop.hbase.PleaseHoldException;
-074import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
-075import
org.apache.hadoop.hbase.ScheduledChore;
+061import
org.apache.hadoop.hbase.ChoreService;
+062import
org.apache.hadoop.hbase.ClusterId;
+063import
org.apache.hadoop.hbase.ClusterMetrics;
+064import
org.apache.hadoop.hbase.ClusterMetrics.Option;
+065import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
+066import
org.apache.hadoop.hbase.DoNotRetryIOException;
+067import
org.apache.hadoop.hbase.HBaseIOException;
+068import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
+069import
org.apache.hadoop.hbase.HConstants;
+070import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
+071import
org.apache.hadoop.hbase.MasterNotRunningException;
+072import
org.apache.hadoop.hbase.MetaTableAccessor;
+073import
org.apache.hadoop.hbase.NamespaceDescriptor;
+074import
org.apache.hadoop.hbase.PleaseHoldException;
+075import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
076import
org.apache.hadoop.hbase.ServerName;
077import
org.apache.hadoop.hbase.TableDescriptors;
078import
org.apache.hadoop.hbase.TableName;
@@ -1277,2505 +1277,2501 @@
1269}
1270 }
1271
-1272 private void
cancelChore(ScheduledChore chore) {
-1273if (chore != null) {
-1274 chore.cancel();
-1275}
-1276 }
-1277
-1278 @Override
-1279 protected void stopServiceThreads()
{
-1280if (masterJettyServer != null) {
-1281 LOG.info("Stopping master jetty
server");
-1282 try {
-1283masterJettyServer.stop();
-1284 } catch (Exception e) {
-1285LOG.error("Failed to stop master
jetty server", e);
-1286 }
-1287}
-1288super.stopServiceThreads();
-1289stopChores();
-1290CleanerChore.shutDownChorePool();
-1291
-1292LOG.debug("Stopping service
threads");
-1293
-1294if (this.quotaManager != null) {
-1295 this.quotaManager.stop();
-1296}
-1297
-1298if (this.activeMasterManager !=
null) {
-1299 this.activeMasterManager.stop();
+1272 @Override
+1273 protected void stopServiceThreads()
{
+1274if (masterJettyServer != null) {
+1275 LOG.info("Stopping master jetty
server");
+1276 try {
+1277masterJettyServer.stop();
+1278 } catch (Exception e) {
+1279LOG.error("Failed to stop master
jetty server", e);
+1280 }
+1281}
+1282stopChores();
+1283if (this.mobCompactThread != null)
{
+1284 this.mobCompactThread.close();
+1285}
+1286super.stopServiceThreads();
+1287CleanerChore.shutDownChorePool();
+1288
+1289LOG.debug("Stopping service
threads");
+1290
+1291if (this.quotaManager != null) {
+1292 this.quotaManager.stop();
+1293}
+1294
+1295if (this.activeMasterManager !=
null) {
+1296 this.activeMasterManager.stop();
+1297}
+1298if (this.serverManager != null) {
+1299 this.serverManager.stop();
1300}
-1301if (this.serverManager != null) {
-1302 this.serverManager.stop();
+1301if (this.assignmentManager != null)
{
+1302 this.assignmentManager.stop();
1303}
-1304if (this.assignmentManager != null)
{
-1305 this.assignmentManager.stop();
-1306}
-1307
-1308stopProcedureExecutor();
-1309
-1310if (this.walManager != null) {
-1311 this.walManager.stop();
+1304
+1305stopProcedureExecutor();
+1306
+1307if (this.walManager != null) {
+1308 this.walManager.stop();
+1309}
+1310if
[06/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
index 7986879..38c8284 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
@@ -2444,1375 +2444,1378 @@
2436 */
2437 protected void stopServiceThreads()
{
2438// clean up the scheduled chores
-2439if (this.choreService != null)
choreService.shutdown();
-2440if (this.nonceManagerChore != null)
nonceManagerChore.cancel(true);
-2441if (this.compactionChecker != null)
compactionChecker.cancel(true);
-2442if (this.periodicFlusher != null)
periodicFlusher.cancel(true);
-2443if (this.healthCheckChore != null)
healthCheckChore.cancel(true);
-2444if (this.storefileRefresher != null)
storefileRefresher.cancel(true);
-2445if (this.movedRegionsCleaner !=
null) movedRegionsCleaner.cancel(true);
-2446if (this.fsUtilizationChore != null)
fsUtilizationChore.cancel(true);
-2447
-2448if (this.cacheFlusher != null) {
-2449 this.cacheFlusher.join();
-2450}
-2451
-2452if (this.spanReceiverHost != null)
{
-2453
this.spanReceiverHost.closeReceivers();
-2454}
-2455if (this.walRoller != null) {
-2456 this.walRoller.close();
+2439if (this.choreService != null) {
+2440
choreService.cancelChore(nonceManagerChore);
+2441
choreService.cancelChore(compactionChecker);
+2442
choreService.cancelChore(periodicFlusher);
+2443
choreService.cancelChore(healthCheckChore);
+2444
choreService.cancelChore(storefileRefresher);
+2445
choreService.cancelChore(movedRegionsCleaner);
+2446
choreService.cancelChore(fsUtilizationChore);
+2447 // clean up the remaining
scheduled chores (in case we missed out any)
+2448 choreService.shutdown();
+2449}
+2450
+2451if (this.cacheFlusher != null) {
+2452 this.cacheFlusher.join();
+2453}
+2454
+2455if (this.spanReceiverHost != null)
{
+2456
this.spanReceiverHost.closeReceivers();
2457}
-2458if (this.compactSplitThread != null)
{
-2459 this.compactSplitThread.join();
+2458if (this.walRoller != null) {
+2459 this.walRoller.close();
2460}
-2461if (this.executorService != null)
this.executorService.shutdown();
-2462if (this.replicationSourceHandler !=
null
-2463this.replicationSourceHandler ==
this.replicationSinkHandler) {
-2464
this.replicationSourceHandler.stopReplicationService();
-2465} else {
-2466 if (this.replicationSourceHandler
!= null) {
-2467
this.replicationSourceHandler.stopReplicationService();
-2468 }
-2469 if (this.replicationSinkHandler !=
null) {
-2470
this.replicationSinkHandler.stopReplicationService();
+2461if (this.compactSplitThread != null)
{
+2462 this.compactSplitThread.join();
+2463}
+2464if (this.executorService != null)
this.executorService.shutdown();
+2465if (this.replicationSourceHandler !=
null
+2466this.replicationSourceHandler ==
this.replicationSinkHandler) {
+2467
this.replicationSourceHandler.stopReplicationService();
+2468} else {
+2469 if (this.replicationSourceHandler
!= null) {
+2470
this.replicationSourceHandler.stopReplicationService();
2471 }
-2472}
-2473 }
-2474
-2475 /**
-2476 * @return Return the object that
implements the replication
-2477 * source executorService.
-2478 */
-2479 @Override
-2480 public ReplicationSourceService
getReplicationSourceService() {
-2481return replicationSourceHandler;
-2482 }
-2483
-2484 /**
-2485 * @return Return the object that
implements the replication sink executorService.
-2486 */
-2487 public ReplicationSinkService
getReplicationSinkService() {
-2488return replicationSinkHandler;
-2489 }
-2490
-2491 /**
-2492 * Get the current master from
ZooKeeper and open the RPC connection to it.
-2493 * To get a fresh connection, the
current rssStub must be null.
-2494 * Method will block until a master is
available. You can break from this
-2495 * block by requesting the server
stop.
-2496 *
-2497 * @return master + port, or null if
server has been stopped
-2498 */
-2499 @VisibleForTesting
-2500 protected synchronized ServerName
createRegionServerStatusStub() {
-2501// Create RS stub without refreshing
the master node from ZK, use cached data
-2502return
createRegionServerStatusStub(false);
-2503 }
-2504
-2505 /**
-2506 * Get the current master from
ZooKeeper and open
[09/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html
index 18136bc9..a5d418c 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html
@@ -66,21 +66,21 @@
058import
org.apache.commons.lang3.StringUtils;
059import
org.apache.hadoop.conf.Configuration;
060import org.apache.hadoop.fs.Path;
-061import
org.apache.hadoop.hbase.ClusterId;
-062import
org.apache.hadoop.hbase.ClusterMetrics;
-063import
org.apache.hadoop.hbase.ClusterMetrics.Option;
-064import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-065import
org.apache.hadoop.hbase.DoNotRetryIOException;
-066import
org.apache.hadoop.hbase.HBaseIOException;
-067import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
-068import
org.apache.hadoop.hbase.HConstants;
-069import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
-070import
org.apache.hadoop.hbase.MasterNotRunningException;
-071import
org.apache.hadoop.hbase.MetaTableAccessor;
-072import
org.apache.hadoop.hbase.NamespaceDescriptor;
-073import
org.apache.hadoop.hbase.PleaseHoldException;
-074import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
-075import
org.apache.hadoop.hbase.ScheduledChore;
+061import
org.apache.hadoop.hbase.ChoreService;
+062import
org.apache.hadoop.hbase.ClusterId;
+063import
org.apache.hadoop.hbase.ClusterMetrics;
+064import
org.apache.hadoop.hbase.ClusterMetrics.Option;
+065import
org.apache.hadoop.hbase.ClusterMetricsBuilder;
+066import
org.apache.hadoop.hbase.DoNotRetryIOException;
+067import
org.apache.hadoop.hbase.HBaseIOException;
+068import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
+069import
org.apache.hadoop.hbase.HConstants;
+070import
org.apache.hadoop.hbase.InvalidFamilyOperationException;
+071import
org.apache.hadoop.hbase.MasterNotRunningException;
+072import
org.apache.hadoop.hbase.MetaTableAccessor;
+073import
org.apache.hadoop.hbase.NamespaceDescriptor;
+074import
org.apache.hadoop.hbase.PleaseHoldException;
+075import
org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
076import
org.apache.hadoop.hbase.ServerName;
077import
org.apache.hadoop.hbase.TableDescriptors;
078import
org.apache.hadoop.hbase.TableName;
@@ -1277,2505 +1277,2501 @@
1269}
1270 }
1271
-1272 private void
cancelChore(ScheduledChore chore) {
-1273if (chore != null) {
-1274 chore.cancel();
-1275}
-1276 }
-1277
-1278 @Override
-1279 protected void stopServiceThreads()
{
-1280if (masterJettyServer != null) {
-1281 LOG.info("Stopping master jetty
server");
-1282 try {
-1283masterJettyServer.stop();
-1284 } catch (Exception e) {
-1285LOG.error("Failed to stop master
jetty server", e);
-1286 }
-1287}
-1288super.stopServiceThreads();
-1289stopChores();
-1290CleanerChore.shutDownChorePool();
-1291
-1292LOG.debug("Stopping service
threads");
-1293
-1294if (this.quotaManager != null) {
-1295 this.quotaManager.stop();
-1296}
-1297
-1298if (this.activeMasterManager !=
null) {
-1299 this.activeMasterManager.stop();
+1272 @Override
+1273 protected void stopServiceThreads()
{
+1274if (masterJettyServer != null) {
+1275 LOG.info("Stopping master jetty
server");
+1276 try {
+1277masterJettyServer.stop();
+1278 } catch (Exception e) {
+1279LOG.error("Failed to stop master
jetty server", e);
+1280 }
+1281}
+1282stopChores();
+1283if (this.mobCompactThread != null)
{
+1284 this.mobCompactThread.close();
+1285}
+1286super.stopServiceThreads();
+1287CleanerChore.shutDownChorePool();
+1288
+1289LOG.debug("Stopping service
threads");
+1290
+1291if (this.quotaManager != null) {
+1292 this.quotaManager.stop();
+1293}
+1294
+1295if (this.activeMasterManager !=
null) {
+1296 this.activeMasterManager.stop();
+1297}
+1298if (this.serverManager != null) {
+1299 this.serverManager.stop();
1300}
-1301if (this.serverManager != null) {
-1302 this.serverManager.stop();
+1301if (this.assignmentManager != null)
{
+1302 this.assignmentManager.stop();
1303}
-1304if (this.assignmentManager != null)
{
-1305 this.assignmentManager.stop();
-1306}
-1307
-1308stopProcedureExecutor();
-1309
-1310if (this.walManager != null) {
-1311 this.walManager.stop();
+1304
+1305stopProcedureExecutor();
+1306
+1307if (this.walManager != null) {
+1308 this.walManager.stop();
+1309}
+1310if (this.fileSystemManager != null)
{
[12/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html index 75a4979..89cf72c 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -704,20 +704,20 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type org.apache.hadoop.hbase.regionserver.HRegion.FlushResult.Result -org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection -org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType -org.apache.hadoop.hbase.regionserver.BloomType -org.apache.hadoop.hbase.regionserver.Region.Operation -org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage +org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status +org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type org.apache.hadoop.hbase.regionserver.ScannerContext.NextState org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope -org.apache.hadoop.hbase.regionserver.FlushType -org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType org.apache.hadoop.hbase.regionserver.ScanType -org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status +org.apache.hadoop.hbase.regionserver.Region.Operation +org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection +org.apache.hadoop.hbase.regionserver.FlushType org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action +org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType +org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage +org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType +org.apache.hadoop.hbase.regionserver.BloomType http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html index f0c55c8..e8df157 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html @@ -247,8 +247,8 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck.Type org.apache.hadoop.hbase.regionserver.wal.CompressionContext.DictionaryIndex +org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck.Type org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrResult http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html index 30c4e73..cd3870f 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html @@ -207,8 +207,8 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceFactoryImpl.SourceHolder
[04/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
index 7986879..38c8284 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
@@ -2444,1375 +2444,1378 @@
2436 */
2437 protected void stopServiceThreads()
{
2438// clean up the scheduled chores
-2439if (this.choreService != null)
choreService.shutdown();
-2440if (this.nonceManagerChore != null)
nonceManagerChore.cancel(true);
-2441if (this.compactionChecker != null)
compactionChecker.cancel(true);
-2442if (this.periodicFlusher != null)
periodicFlusher.cancel(true);
-2443if (this.healthCheckChore != null)
healthCheckChore.cancel(true);
-2444if (this.storefileRefresher != null)
storefileRefresher.cancel(true);
-2445if (this.movedRegionsCleaner !=
null) movedRegionsCleaner.cancel(true);
-2446if (this.fsUtilizationChore != null)
fsUtilizationChore.cancel(true);
-2447
-2448if (this.cacheFlusher != null) {
-2449 this.cacheFlusher.join();
-2450}
-2451
-2452if (this.spanReceiverHost != null)
{
-2453
this.spanReceiverHost.closeReceivers();
-2454}
-2455if (this.walRoller != null) {
-2456 this.walRoller.close();
+2439if (this.choreService != null) {
+2440
choreService.cancelChore(nonceManagerChore);
+2441
choreService.cancelChore(compactionChecker);
+2442
choreService.cancelChore(periodicFlusher);
+2443
choreService.cancelChore(healthCheckChore);
+2444
choreService.cancelChore(storefileRefresher);
+2445
choreService.cancelChore(movedRegionsCleaner);
+2446
choreService.cancelChore(fsUtilizationChore);
+2447 // clean up the remaining
scheduled chores (in case we missed out any)
+2448 choreService.shutdown();
+2449}
+2450
+2451if (this.cacheFlusher != null) {
+2452 this.cacheFlusher.join();
+2453}
+2454
+2455if (this.spanReceiverHost != null)
{
+2456
this.spanReceiverHost.closeReceivers();
2457}
-2458if (this.compactSplitThread != null)
{
-2459 this.compactSplitThread.join();
+2458if (this.walRoller != null) {
+2459 this.walRoller.close();
2460}
-2461if (this.executorService != null)
this.executorService.shutdown();
-2462if (this.replicationSourceHandler !=
null
-2463this.replicationSourceHandler ==
this.replicationSinkHandler) {
-2464
this.replicationSourceHandler.stopReplicationService();
-2465} else {
-2466 if (this.replicationSourceHandler
!= null) {
-2467
this.replicationSourceHandler.stopReplicationService();
-2468 }
-2469 if (this.replicationSinkHandler !=
null) {
-2470
this.replicationSinkHandler.stopReplicationService();
+2461if (this.compactSplitThread != null)
{
+2462 this.compactSplitThread.join();
+2463}
+2464if (this.executorService != null)
this.executorService.shutdown();
+2465if (this.replicationSourceHandler !=
null
+2466this.replicationSourceHandler ==
this.replicationSinkHandler) {
+2467
this.replicationSourceHandler.stopReplicationService();
+2468} else {
+2469 if (this.replicationSourceHandler
!= null) {
+2470
this.replicationSourceHandler.stopReplicationService();
2471 }
-2472}
-2473 }
-2474
-2475 /**
-2476 * @return Return the object that
implements the replication
-2477 * source executorService.
-2478 */
-2479 @Override
-2480 public ReplicationSourceService
getReplicationSourceService() {
-2481return replicationSourceHandler;
-2482 }
-2483
-2484 /**
-2485 * @return Return the object that
implements the replication sink executorService.
-2486 */
-2487 public ReplicationSinkService
getReplicationSinkService() {
-2488return replicationSinkHandler;
-2489 }
-2490
-2491 /**
-2492 * Get the current master from
ZooKeeper and open the RPC connection to it.
-2493 * To get a fresh connection, the
current rssStub must be null.
-2494 * Method will block until a master is
available. You can break from this
-2495 * block by requesting the server
stop.
-2496 *
-2497 * @return master + port, or null if
server has been stopped
-2498 */
-2499 @VisibleForTesting
-2500 protected synchronized ServerName
createRegionServerStatusStub() {
-2501// Create RS stub without refreshing
the master node from ZK, use cached data
-2502return
createRegionServerStatusStub(false);
-2503 }
-2504
-2505 /**
-2506 * Get the current master from
ZooKeeper
hbase-site git commit: INFRA-10751 Empty commit
Repository: hbase-site Updated Branches: refs/heads/asf-site f6b26c52e -> 9a2ffdb82 INFRA-10751 Empty commit Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/9a2ffdb8 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/9a2ffdb8 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/9a2ffdb8 Branch: refs/heads/asf-site Commit: 9a2ffdb8256a8f4b5fd1573e45255f8aac9cfe45 Parents: f6b26c5 Author: jenkins Authored: Fri Jul 6 14:49:12 2018 + Committer: jenkins Committed: Fri Jul 6 14:49:12 2018 + -- --
[01/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
Repository: hbase-site Updated Branches: refs/heads/asf-site 6b0c5ee8d -> f6b26c52e http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/downloads.html -- diff --git a/downloads.html b/downloads.html index 4db8984..22aed36 100644 --- a/downloads.html +++ b/downloads.html @@ -7,7 +7,7 @@ - + Apache HBase Apache HBase Downloads @@ -404,7 +404,7 @@ under the License. --> https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/export_control.html -- diff --git a/export_control.html b/export_control.html index 2b87f1f..aa62338 100644 --- a/export_control.html +++ b/export_control.html @@ -7,7 +7,7 @@ - + Apache HBase Export Control @@ -331,7 +331,7 @@ for more details. https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/index.html -- diff --git a/index.html b/index.html index 1d63ff6..9e0508f 100644 --- a/index.html +++ b/index.html @@ -7,7 +7,7 @@ - + Apache HBase Apache HBase⢠Home @@ -411,7 +411,7 @@ Apache HBase is an open-source, distributed, versioned, non-relational database https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/integration.html -- diff --git a/integration.html b/integration.html index 4bef95a..701e376 100644 --- a/integration.html +++ b/integration.html @@ -7,7 +7,7 @@ - + Apache HBase CI Management @@ -291,7 +291,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/issue-tracking.html -- diff --git a/issue-tracking.html b/issue-tracking.html index 67185fd..af86acf 100644 --- a/issue-tracking.html +++ b/issue-tracking.html @@ -7,7 +7,7 @@ - + Apache HBase Issue Management @@ -288,7 +288,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/license.html -- diff --git a/license.html b/license.html index 514b875..76a6358 100644 --- a/license.html +++ b/license.html @@ -7,7 +7,7 @@ - + Apache HBase Project Licenses @@ -491,7 +491,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/mail-lists.html -- diff --git a/mail-lists.html b/mail-lists.html index 32f0933..a7ca99e 100644 --- a/mail-lists.html +++ b/mail-lists.html @@ -7,7 +7,7 @@ - + Apache HBase Project Mailing Lists @@ -341,7 +341,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-04 + Last Published: 2018-07-06 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/metrics.html -- diff --git
[02/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html
index 7986879..38c8284 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html
@@ -2444,1375 +2444,1378 @@
2436 */
2437 protected void stopServiceThreads()
{
2438// clean up the scheduled chores
-2439if (this.choreService != null)
choreService.shutdown();
-2440if (this.nonceManagerChore != null)
nonceManagerChore.cancel(true);
-2441if (this.compactionChecker != null)
compactionChecker.cancel(true);
-2442if (this.periodicFlusher != null)
periodicFlusher.cancel(true);
-2443if (this.healthCheckChore != null)
healthCheckChore.cancel(true);
-2444if (this.storefileRefresher != null)
storefileRefresher.cancel(true);
-2445if (this.movedRegionsCleaner !=
null) movedRegionsCleaner.cancel(true);
-2446if (this.fsUtilizationChore != null)
fsUtilizationChore.cancel(true);
-2447
-2448if (this.cacheFlusher != null) {
-2449 this.cacheFlusher.join();
-2450}
-2451
-2452if (this.spanReceiverHost != null)
{
-2453
this.spanReceiverHost.closeReceivers();
-2454}
-2455if (this.walRoller != null) {
-2456 this.walRoller.close();
+2439if (this.choreService != null) {
+2440
choreService.cancelChore(nonceManagerChore);
+2441
choreService.cancelChore(compactionChecker);
+2442
choreService.cancelChore(periodicFlusher);
+2443
choreService.cancelChore(healthCheckChore);
+2444
choreService.cancelChore(storefileRefresher);
+2445
choreService.cancelChore(movedRegionsCleaner);
+2446
choreService.cancelChore(fsUtilizationChore);
+2447 // clean up the remaining
scheduled chores (in case we missed out any)
+2448 choreService.shutdown();
+2449}
+2450
+2451if (this.cacheFlusher != null) {
+2452 this.cacheFlusher.join();
+2453}
+2454
+2455if (this.spanReceiverHost != null)
{
+2456
this.spanReceiverHost.closeReceivers();
2457}
-2458if (this.compactSplitThread != null)
{
-2459 this.compactSplitThread.join();
+2458if (this.walRoller != null) {
+2459 this.walRoller.close();
2460}
-2461if (this.executorService != null)
this.executorService.shutdown();
-2462if (this.replicationSourceHandler !=
null
-2463this.replicationSourceHandler ==
this.replicationSinkHandler) {
-2464
this.replicationSourceHandler.stopReplicationService();
-2465} else {
-2466 if (this.replicationSourceHandler
!= null) {
-2467
this.replicationSourceHandler.stopReplicationService();
-2468 }
-2469 if (this.replicationSinkHandler !=
null) {
-2470
this.replicationSinkHandler.stopReplicationService();
+2461if (this.compactSplitThread != null)
{
+2462 this.compactSplitThread.join();
+2463}
+2464if (this.executorService != null)
this.executorService.shutdown();
+2465if (this.replicationSourceHandler !=
null
+2466this.replicationSourceHandler ==
this.replicationSinkHandler) {
+2467
this.replicationSourceHandler.stopReplicationService();
+2468} else {
+2469 if (this.replicationSourceHandler
!= null) {
+2470
this.replicationSourceHandler.stopReplicationService();
2471 }
-2472}
-2473 }
-2474
-2475 /**
-2476 * @return Return the object that
implements the replication
-2477 * source executorService.
-2478 */
-2479 @Override
-2480 public ReplicationSourceService
getReplicationSourceService() {
-2481return replicationSourceHandler;
-2482 }
-2483
-2484 /**
-2485 * @return Return the object that
implements the replication sink executorService.
-2486 */
-2487 public ReplicationSinkService
getReplicationSinkService() {
-2488return replicationSinkHandler;
-2489 }
-2490
-2491 /**
-2492 * Get the current master from
ZooKeeper and open the RPC connection to it.
-2493 * To get a fresh connection, the
current rssStub must be null.
-2494 * Method will block until a master is
available. You can break from this
-2495 * block by requesting the server
stop.
-2496 *
-2497 * @return master + port, or null if
server has been stopped
-2498 */
-2499 @VisibleForTesting
-2500 protected synchronized ServerName
createRegionServerStatusStub() {
-2501// Create RS stub without refreshing
the master node from ZK, use cached data
-2502return
createRegionServerStatusStub(false);
-2503 }
-2504
-2505 /**
-2506 * Get the current master from
ZooKeeper and open the RPC connection to it. To get a fresh
-2507 * connection, the current rssStub
must be
[05/17] hbase-site git commit: Published site at 1ade4d2f440a629968d41487bf27062a7e22f08b.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f6b26c52/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
index 7986879..38c8284 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
@@ -2444,1375 +2444,1378 @@
2436 */
2437 protected void stopServiceThreads()
{
2438// clean up the scheduled chores
-2439if (this.choreService != null)
choreService.shutdown();
-2440if (this.nonceManagerChore != null)
nonceManagerChore.cancel(true);
-2441if (this.compactionChecker != null)
compactionChecker.cancel(true);
-2442if (this.periodicFlusher != null)
periodicFlusher.cancel(true);
-2443if (this.healthCheckChore != null)
healthCheckChore.cancel(true);
-2444if (this.storefileRefresher != null)
storefileRefresher.cancel(true);
-2445if (this.movedRegionsCleaner !=
null) movedRegionsCleaner.cancel(true);
-2446if (this.fsUtilizationChore != null)
fsUtilizationChore.cancel(true);
-2447
-2448if (this.cacheFlusher != null) {
-2449 this.cacheFlusher.join();
-2450}
-2451
-2452if (this.spanReceiverHost != null)
{
-2453
this.spanReceiverHost.closeReceivers();
-2454}
-2455if (this.walRoller != null) {
-2456 this.walRoller.close();
+2439if (this.choreService != null) {
+2440
choreService.cancelChore(nonceManagerChore);
+2441
choreService.cancelChore(compactionChecker);
+2442
choreService.cancelChore(periodicFlusher);
+2443
choreService.cancelChore(healthCheckChore);
+2444
choreService.cancelChore(storefileRefresher);
+2445
choreService.cancelChore(movedRegionsCleaner);
+2446
choreService.cancelChore(fsUtilizationChore);
+2447 // clean up the remaining
scheduled chores (in case we missed out any)
+2448 choreService.shutdown();
+2449}
+2450
+2451if (this.cacheFlusher != null) {
+2452 this.cacheFlusher.join();
+2453}
+2454
+2455if (this.spanReceiverHost != null)
{
+2456
this.spanReceiverHost.closeReceivers();
2457}
-2458if (this.compactSplitThread != null)
{
-2459 this.compactSplitThread.join();
+2458if (this.walRoller != null) {
+2459 this.walRoller.close();
2460}
-2461if (this.executorService != null)
this.executorService.shutdown();
-2462if (this.replicationSourceHandler !=
null
-2463this.replicationSourceHandler ==
this.replicationSinkHandler) {
-2464
this.replicationSourceHandler.stopReplicationService();
-2465} else {
-2466 if (this.replicationSourceHandler
!= null) {
-2467
this.replicationSourceHandler.stopReplicationService();
-2468 }
-2469 if (this.replicationSinkHandler !=
null) {
-2470
this.replicationSinkHandler.stopReplicationService();
+2461if (this.compactSplitThread != null)
{
+2462 this.compactSplitThread.join();
+2463}
+2464if (this.executorService != null)
this.executorService.shutdown();
+2465if (this.replicationSourceHandler !=
null
+2466this.replicationSourceHandler ==
this.replicationSinkHandler) {
+2467
this.replicationSourceHandler.stopReplicationService();
+2468} else {
+2469 if (this.replicationSourceHandler
!= null) {
+2470
this.replicationSourceHandler.stopReplicationService();
2471 }
-2472}
-2473 }
-2474
-2475 /**
-2476 * @return Return the object that
implements the replication
-2477 * source executorService.
-2478 */
-2479 @Override
-2480 public ReplicationSourceService
getReplicationSourceService() {
-2481return replicationSourceHandler;
-2482 }
-2483
-2484 /**
-2485 * @return Return the object that
implements the replication sink executorService.
-2486 */
-2487 public ReplicationSinkService
getReplicationSinkService() {
-2488return replicationSinkHandler;
-2489 }
-2490
-2491 /**
-2492 * Get the current master from
ZooKeeper and open the RPC connection to it.
-2493 * To get a fresh connection, the
current rssStub must be null.
-2494 * Method will block until a master is
available. You can break from this
-2495 * block by requesting the server
stop.
-2496 *
-2497 * @return master + port, or null if
server has been stopped
-2498 */
-2499 @VisibleForTesting
-2500 protected synchronized ServerName
createRegionServerStatusStub() {
-2501// Create RS stub without refreshing
the master node from ZK, use cached data
-2502return
createRegionServerStatusStub(false);
-2503 }
-2504
-2505 /**
-2506 * Get the current master from
ZooKeeper and open the RPC
[hbase] Git Push Summary
Repository: hbase Updated Tags: refs/tags/2.1.0RC0 [created] 405250662
[2/2] hbase git commit: HBASE-20849 Set version as 2.1.0 in branch-2.1 in prep for first RC
HBASE-20849 Set version as 2.1.0 in branch-2.1 in prep for first RC Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a2db3d27 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a2db3d27 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a2db3d27 Branch: refs/heads/branch-2.1 Commit: a2db3d27ffd35c9b037237a909c79ae6194dcec5 Parents: 159f1b4 Author: zhangduo Authored: Fri Jul 6 08:42:06 2018 +0800 Committer: zhangduo Committed: Fri Jul 6 15:32:23 2018 +0800 -- hbase-annotations/pom.xml | 2 +- hbase-archetypes/hbase-archetype-builder/pom.xml | 2 +- hbase-archetypes/hbase-client-project/pom.xml | 2 +- hbase-archetypes/hbase-shaded-client-project/pom.xml | 2 +- hbase-archetypes/pom.xml | 2 +- hbase-assembly/pom.xml | 2 +- hbase-build-configuration/pom.xml | 2 +- hbase-build-support/hbase-error-prone/pom.xml | 4 ++-- hbase-build-support/pom.xml| 2 +- hbase-checkstyle/pom.xml | 4 ++-- hbase-client/pom.xml | 2 +- hbase-common/pom.xml | 2 +- hbase-endpoint/pom.xml | 2 +- hbase-examples/pom.xml | 2 +- hbase-external-blockcache/pom.xml | 2 +- hbase-hadoop-compat/pom.xml| 2 +- hbase-hadoop2-compat/pom.xml | 2 +- hbase-http/pom.xml | 2 +- hbase-it/pom.xml | 2 +- hbase-mapreduce/pom.xml| 2 +- hbase-metrics-api/pom.xml | 2 +- hbase-metrics/pom.xml | 2 +- hbase-procedure/pom.xml| 2 +- hbase-protocol-shaded/pom.xml | 2 +- hbase-protocol/pom.xml | 2 +- hbase-replication/pom.xml | 2 +- hbase-resource-bundle/pom.xml | 2 +- hbase-rest/pom.xml | 2 +- hbase-rsgroup/pom.xml | 2 +- hbase-server/pom.xml | 2 +- hbase-shaded/hbase-shaded-check-invariants/pom.xml | 2 +- hbase-shaded/hbase-shaded-client-byo-hadoop/pom.xml| 2 +- hbase-shaded/hbase-shaded-client/pom.xml | 2 +- hbase-shaded/hbase-shaded-mapreduce/pom.xml| 2 +- hbase-shaded/hbase-shaded-with-hadoop-check-invariants/pom.xml | 2 +- hbase-shaded/pom.xml | 2 +- hbase-shell/pom.xml| 2 +- hbase-testing-util/pom.xml | 2 +- hbase-thrift/pom.xml | 2 +- hbase-zookeeper/pom.xml| 2 +- pom.xml| 2 +- 41 files changed, 43 insertions(+), 43 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/a2db3d27/hbase-annotations/pom.xml -- diff --git a/hbase-annotations/pom.xml b/hbase-annotations/pom.xml index 63a2e55..698335c 100644 --- a/hbase-annotations/pom.xml +++ b/hbase-annotations/pom.xml @@ -23,7 +23,7 @@ hbase org.apache.hbase -2.1.0-SNAPSHOT +2.1.0 .. http://git-wip-us.apache.org/repos/asf/hbase/blob/a2db3d27/hbase-archetypes/hbase-archetype-builder/pom.xml -- diff --git a/hbase-archetypes/hbase-archetype-builder/pom.xml b/hbase-archetypes/hbase-archetype-builder/pom.xml index fd9779f..fc425b5 100644 --- a/hbase-archetypes/hbase-archetype-builder/pom.xml +++ b/hbase-archetypes/hbase-archetype-builder/pom.xml @@ -25,7 +25,7 @@ hbase-archetypes org.apache.hbase -2.1.0-SNAPSHOT +2.1.0 .. http://git-wip-us.apache.org/repos/asf/hbase/blob/a2db3d27/hbase-archetypes/hbase-client-project/pom.xml -- diff --git a/hbase-archetypes/hbase-client-project/pom.xml b/hbase-archetypes/hbase-client-project/pom.xml index 4eccad3..8c321c5 100644 --- a/hbase-archetypes/hbase-client-project/pom.xml +++
[1/2] hbase git commit: Revert "HBASE-20808 Wrong shutdown order between Chores and ChoreService"
Repository: hbase
Updated Branches:
refs/heads/branch-2.1 ae2c858c5 -> a2db3d27f
Revert "HBASE-20808 Wrong shutdown order between Chores and ChoreService"
For cutting 2.1.0RC0
This reverts commit ae2c858c5ef30695d939af748cba1080be0ce970.
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/159f1b46
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/159f1b46
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/159f1b46
Branch: refs/heads/branch-2.1
Commit: 159f1b468607c7cc9d0d3caf344daf94281e248b
Parents: ae2c858
Author: zhangduo
Authored: Fri Jul 6 15:29:58 2018 +0800
Committer: zhangduo
Committed: Fri Jul 6 15:29:58 2018 +0800
--
.../org/apache/hadoop/hbase/master/HMaster.java | 40 +++-
.../hbase/regionserver/HRegionServer.java | 19 --
2 files changed, 30 insertions(+), 29 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/159f1b46/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index f0e6711..a5e07ba 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -58,7 +58,6 @@ import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.hbase.ChoreService;
import org.apache.hadoop.hbase.ClusterId;
import org.apache.hadoop.hbase.ClusterMetrics;
import org.apache.hadoop.hbase.ClusterMetrics.Option;
@@ -73,6 +72,7 @@ import org.apache.hadoop.hbase.MetaTableAccessor;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.PleaseHoldException;
import org.apache.hadoop.hbase.ReplicationPeerNotFoundException;
+import org.apache.hadoop.hbase.ScheduledChore;
import org.apache.hadoop.hbase.ServerName;
import org.apache.hadoop.hbase.TableDescriptors;
import org.apache.hadoop.hbase.TableName;
@@ -1255,6 +1255,12 @@ public class HMaster extends HRegionServer implements
MasterServices {
}
}
+ private void cancelChore(ScheduledChore chore) {
+if (chore != null) {
+ chore.cancel();
+}
+ }
+
@Override
protected void stopServiceThreads() {
if (masterJettyServer != null) {
@@ -1265,11 +1271,8 @@ public class HMaster extends HRegionServer implements
MasterServices {
LOG.error("Failed to stop master jetty server", e);
}
}
-stopChores();
-if (this.mobCompactThread != null) {
- this.mobCompactThread.close();
-}
super.stopServiceThreads();
+stopChores();
CleanerChore.shutDownChorePool();
LOG.debug("Stopping service threads");
@@ -1347,20 +1350,21 @@ public class HMaster extends HRegionServer implements
MasterServices {
}
private void stopChores() {
-ChoreService choreService = getChoreService();
-if (choreService != null) {
- choreService.cancelChore(this.expiredMobFileCleanerChore);
- choreService.cancelChore(this.mobCompactChore);
- choreService.cancelChore(this.balancerChore);
- choreService.cancelChore(this.normalizerChore);
- choreService.cancelChore(this.clusterStatusChore);
- choreService.cancelChore(this.catalogJanitorChore);
- choreService.cancelChore(this.clusterStatusPublisherChore);
- choreService.cancelChore(this.snapshotQuotaChore);
- choreService.cancelChore(this.logCleaner);
- choreService.cancelChore(this.hfileCleaner);
- choreService.cancelChore(this.replicationBarrierCleaner);
+cancelChore(this.expiredMobFileCleanerChore);
+cancelChore(this.mobCompactChore);
+cancelChore(this.balancerChore);
+cancelChore(this.normalizerChore);
+cancelChore(this.clusterStatusChore);
+cancelChore(this.catalogJanitorChore);
+cancelChore(this.clusterStatusPublisherChore);
+if (this.mobCompactThread != null) {
+ this.mobCompactThread.close();
}
+cancelChore(this.clusterStatusPublisherChore);
+cancelChore(this.snapshotQuotaChore);
+cancelChore(this.logCleaner);
+cancelChore(this.hfileCleaner);
+cancelChore(this.replicationBarrierCleaner);
}
/**
http://git-wip-us.apache.org/repos/asf/hbase/blob/159f1b46/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
