This is an automated email from the ASF dual-hosted git repository. yiyang0203 pushed a commit to branch HDDS-5713 in repository https://gitbox.apache.org/repos/asf/ozone.git
commit a2ad71fc3e7abb1594e869da9753d7598c071a96 Author: Stephen O'Donnell <[email protected]> AuthorDate: Thu Feb 8 22:06:32 2024 +0000 HDDS-10305. [DiskBalancer] Disk balancer command is not registered on datanode (#6188) Co-authored-by: S O'Donnell <[email protected]> --- .../statemachine/commandhandler/DiskBalancerCommandHandler.java | 2 +- .../apache/hadoop/hdds/scm/server/SCMDatanodeProtocolServer.java | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DiskBalancerCommandHandler.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DiskBalancerCommandHandler.java index 6ff745cafe..66bb3725b4 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DiskBalancerCommandHandler.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/DiskBalancerCommandHandler.java @@ -71,7 +71,7 @@ public class DiskBalancerCommandHandler implements CommandHandler { diskBalancerCommand.getDiskBalancerConfiguration(); DiskBalancerInfo diskBalancerInfo = ozoneContainer.getDiskBalancerInfo(); - + LOG.info("Processing {}", diskBalancerCommand); try { switch (opType) { case START: diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMDatanodeProtocolServer.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMDatanodeProtocolServer.java index 3d864d4ea2..5a4ea85752 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMDatanodeProtocolServer.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMDatanodeProtocolServer.java @@ -72,6 +72,7 @@ import org.apache.hadoop.ozone.protocol.commands.ClosePipelineCommand; import org.apache.hadoop.ozone.protocol.commands.CreatePipelineCommand; import org.apache.hadoop.ozone.protocol.commands.DeleteBlocksCommand; import org.apache.hadoop.ozone.protocol.commands.DeleteContainerCommand; +import org.apache.hadoop.ozone.protocol.commands.DiskBalancerCommand; import org.apache.hadoop.ozone.protocol.commands.FinalizeNewLayoutVersionCommand; import org.apache.hadoop.ozone.protocol.commands.RefreshVolumeUsageCommand; import org.apache.hadoop.ozone.protocol.commands.RegisteredCommand; @@ -407,7 +408,11 @@ public class SCMDatanodeProtocolServer implements .setRefreshVolumeUsageCommandProto( ((RefreshVolumeUsageCommand)cmd).getProto()) .build(); - + case diskBalancerCommand: + return builder + .setCommandType(SCMCommandProto.Type.diskBalancerCommand) + .setDiskBalancerCommandProto(((DiskBalancerCommand)cmd).getProto()) + .build(); default: throw new IllegalArgumentException("Scm command " + cmd.getType().toString() + " is not implemented"); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
