This is an automated email from the ASF dual-hosted git repository.
sodonnell pushed a commit to branch HDDS-5713
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/HDDS-5713 by this push:
new 685f4ca474 HDDS-10305. [DiskBalancer] Disk balancer command is not
registered on datanode (#6188)
685f4ca474 is described below
commit 685f4ca47491f43d8348454a4ff41aa39a9f9292
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]
