You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by na...@apache.org on 2020/04/07 18:22:25 UTC
[hadoop-ozone] branch master updated: HDDS-3348. scmcli container
info command shows the wrong container state. (#776)
This is an automated email from the ASF dual-hosted git repository.
nanda pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
The following commit(s) were added to refs/heads/master by this push:
new de30b37 HDDS-3348. scmcli container info command shows the wrong container state. (#776)
de30b37 is described below
commit de30b3788d3211c2103835760fddbd43d4cad41e
Author: Nandakumar <na...@apache.org>
AuthorDate: Tue Apr 7 23:52:15 2020 +0530
HDDS-3348. scmcli container info command shows the wrong container state. (#776)
---
.../hdds/scm/cli/container/InfoSubcommand.java | 20 +++-----------------
1 file changed, 3 insertions(+), 17 deletions(-)
diff --git a/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/container/InfoSubcommand.java b/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/container/InfoSubcommand.java
index 31fdb1d..ec871f9 100644
--- a/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/container/InfoSubcommand.java
+++ b/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/container/InfoSubcommand.java
@@ -22,8 +22,6 @@ import java.util.stream.Collectors;
import org.apache.hadoop.hdds.cli.HddsVersionProvider;
import org.apache.hadoop.hdds.protocol.DatanodeDetails;
-import org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos
- .ContainerDataProto;
import org.apache.hadoop.hdds.scm.client.ScmClient;
import org.apache.hadoop.hdds.scm.container.common.helpers
.ContainerWithPipeline;
@@ -57,26 +55,14 @@ public class InfoSubcommand implements Callable<Void> {
@Override
public Void call() throws Exception {
try (ScmClient scmClient = parent.getParent().createScmClient()) {
- ContainerWithPipeline container = scmClient.
+ final ContainerWithPipeline container = scmClient.
getContainerWithPipeline(containerID);
Preconditions.checkNotNull(container, "Container cannot be null");
- ContainerDataProto containerData = scmClient.readContainer(container
- .getContainerInfo().getContainerID(), container.getPipeline());
-
// Print container report info.
LOG.info("Container id: {}", containerID);
- String openStatus =
- containerData.getState() == ContainerDataProto.State.OPEN ? "OPEN" :
- "CLOSED";
- LOG.info("Container State: {}", openStatus);
- LOG.info("Container Path: {}", containerData.getContainerPath());
-
- // Output meta data.
- String metadataStr = containerData.getMetadataList().stream().map(
- p -> p.getKey() + ":" + p.getValue())
- .collect(Collectors.joining(", "));
- LOG.info("Container Metadata: {}", metadataStr);
+ LOG.info("Pipeline id: {}", container.getPipeline().getId().getId());
+ LOG.info("Container State: {}", container.getContainerInfo().getState());
// Print pipeline of an existing container.
String machinesStr = container.getPipeline().getNodes().stream().map(
---------------------------------------------------------------------
To unsubscribe, e-mail: ozone-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: ozone-commits-help@hadoop.apache.org