You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2016/11/03 18:10:05 UTC
hbase git commit: HBASE-17014 Added clearly marked log messages for
start and shutdown of services HMaster, HRegionServer, ThriftServer,
RESTServer. Also changed the log level for RPCServer responder starting log
message to debug.
Repository: hbase
Updated Branches:
refs/heads/master de97933aa -> 281bf9a22
HBASE-17014 Added clearly marked log messages for start and shutdown of services HMaster, HRegionServer, ThriftServer, RESTServer. Also changed the log level for RPCServer responder starting log message to debug.
Signed-off-by: Michael Stack <st...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/281bf9a2
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/281bf9a2
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/281bf9a2
Branch: refs/heads/master
Commit: 281bf9a222a3eae006198fb067f227721f723996
Parents: de97933
Author: Umesh Agashe <ua...@cloudera.com>
Authored: Thu Nov 3 10:27:01 2016 -0700
Committer: Michael Stack <st...@apache.org>
Committed: Thu Nov 3 11:09:55 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java | 2 ++
.../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java | 2 +-
.../src/main/java/org/apache/hadoop/hbase/master/HMaster.java | 1 +
.../org/apache/hadoop/hbase/regionserver/HRegionServer.java | 4 +++-
.../main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java | 6 +++++-
5 files changed, 12 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/281bf9a2/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java
----------------------------------------------------------------------
diff --git a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java
index a5c78bf..00fd834 100644
--- a/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java
+++ b/hbase-rest/src/main/java/org/apache/hadoop/hbase/rest/RESTServer.java
@@ -213,6 +213,7 @@ public class RESTServer implements Constants {
* @throws Exception exception
*/
public static void main(String[] args) throws Exception {
+ LOG.info("***** STARTING service '" + RESTServer.class.getSimpleName() + "' *****");
VersionInfo.logVersion();
Configuration conf = HBaseConfiguration.create();
UserProvider userProvider = UserProvider.instantiate(conf);
@@ -313,5 +314,6 @@ public class RESTServer implements Constants {
// start server
server.start();
server.join();
+ LOG.info("***** STOPPING service '" + RESTServer.class.getSimpleName() + "' *****");
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/281bf9a2/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
index 64fe835..1c2d51f 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
@@ -1015,7 +1015,7 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver {
@Override
public void run() {
- LOG.info(getName() + ": starting");
+ LOG.debug(getName() + ": starting");
try {
doRunLoop();
} finally {
http://git-wip-us.apache.org/repos/asf/hbase/blob/281bf9a2/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 beec198..4171872 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
@@ -2476,6 +2476,7 @@ public class HMaster extends HRegionServer implements MasterServices {
* @see org.apache.hadoop.hbase.master.HMasterCommandLine
*/
public static void main(String [] args) {
+ LOG.info("***** STARTING service '" + HMaster.class.getSimpleName() + "' *****");
VersionInfo.logVersion();
new HMasterCommandLine(HMaster.class).doMain(args);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/281bf9a2/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 495aace..73dc265 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
@@ -1953,6 +1953,7 @@ public class HRegionServer extends HasThread implements
@Override
public void stop(final String msg) {
if (!this.stopped) {
+ LOG.info("***** STOPPING region server '" + this + "' *****");
try {
if (this.rsHost != null) {
this.rsHost.preStop(msg);
@@ -2226,7 +2227,7 @@ public class HRegionServer extends HasThread implements
*/
@Override
public void abort(String reason, Throwable cause) {
- String msg = "ABORTING region server " + this + ": " + reason;
+ String msg = "***** ABORTING region server " + this + ": " + reason + " *****";
if (cause != null) {
LOG.fatal(msg, cause);
} else {
@@ -2851,6 +2852,7 @@ public class HRegionServer extends HasThread implements
* @see org.apache.hadoop.hbase.regionserver.HRegionServerCommandLine
*/
public static void main(String[] args) throws Exception {
+ LOG.info("***** STARTING service '" + HRegionServer.class.getSimpleName() + "' *****");
VersionInfo.logVersion();
Configuration conf = HBaseConfiguration.create();
@SuppressWarnings("unchecked")
http://git-wip-us.apache.org/repos/asf/hbase/blob/281bf9a2/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
----------------------------------------------------------------------
diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
index 560f788..254c4b7 100644
--- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
+++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/ThriftServer.java
@@ -235,11 +235,15 @@ public class ThriftServer {
* @throws Exception
*/
public static void main(String [] args) throws Exception {
+ LOG.info("***** STARTING service '" + ThriftServer.class.getSimpleName() + "' *****");
VersionInfo.logVersion();
+ int exitCode = 0;
try {
new ThriftServer(HBaseConfiguration.create()).doMain(args);
} catch (ExitCodeException ex) {
- System.exit(ex.getExitCode());
+ exitCode = ex.getExitCode();
}
+ LOG.info("***** STOPPING service '" + ThriftServer.class.getSimpleName() + "' *****");
+ System.exit(exitCode);
}
}