Repository: hadoop
Updated Branches:
  refs/heads/ozone-0.2 0d3406e25 -> 54ec2366e


HDDS-431. LeaseManager of CommandWatcher is not started.
Contributed by Elek, Marton.

(cherry picked from commit 8ffbbf51c9a0f9bbcd9ee7452d95e588a2cb87ac)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/54ec2366
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/54ec2366
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/54ec2366

Branch: refs/heads/ozone-0.2
Commit: 54ec2366e217254fdc84040842353d6b7fc115ce
Parents: 0d3406e
Author: Anu Engineer <[email protected]>
Authored: Tue Sep 11 10:44:47 2018 -0700
Committer: Anu Engineer <[email protected]>
Committed: Tue Sep 11 10:51:06 2018 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/hdds/scm/server/StorageContainerManager.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/54ec2366/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
----------------------------------------------------------------------
diff --git 
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
 
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
index f505430..67d5496 100644
--- 
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
+++ 
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
@@ -613,6 +613,8 @@ public final class StorageContainerManager extends 
ServiceRuntimeInfoImpl
             "StorageContainerLocationProtocol RPC server",
             getClientRpcAddress()));
     DefaultMetricsSystem.initialize("StorageContainerManager");
+
+    commandWatcherLeaseManager.start();
     getClientProtocolServer().start();
 
     LOG.info(buildRpcServerStartMessage("ScmBlockLocationProtocol RPC " +


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to