This is an automated email from the ASF dual-hosted git repository. captainzmc pushed a commit to branch HDDS-4454 in repository https://gitbox.apache.org/repos/asf/ozone.git
commit bda70049ff1c608fb549676ddd099cb5b2b1206c Author: Kaijie Chen <[email protected]> AuthorDate: Thu Jul 22 19:46:31 2021 +0800 HDDS-5481. Fix stream() and link() method in ContainerStateMachine. (#2451) --- .../common/transport/server/ratis/ContainerStateMachine.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java index f8d066757a..121a6d6bdd 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java @@ -518,8 +518,7 @@ public class ContainerStateMachine extends BaseStateMachine { return CompletableFuture.supplyAsync(() -> { try { ContainerCommandRequestProto requestProto = - getContainerCommandRequestProto(gid, - request.getMessage().getContent()); + message2ContainerCommandRequestProto(request.getMessage()); DispatcherContext context = new DispatcherContext.Builder() .setStage(DispatcherContext.WriteChunkStage.WRITE_DATA) @@ -536,6 +535,7 @@ public class ContainerStateMachine extends BaseStateMachine { }, executor); } + @Override public CompletableFuture<?> link(DataStream stream, LogEntryProto entry) { return CompletableFuture.supplyAsync(() -> { if (stream == null) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
