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 9d0b07e8c25c4bd1e3542dcf9be9b063db90fe5c Author: hao guo <[email protected]> AuthorDate: Mon Apr 18 11:28:27 2022 +0800 HDDS-6592. [Ozone-Streaming] Fix ContainerStateMachine#applyTransaction assert error (#3315) --- .../container/common/transport/server/ratis/ContainerStateMachine.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 b9707e5af2..f6f5a99927 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 @@ -879,7 +879,8 @@ public class ContainerStateMachine extends BaseStateMachine { builder.setStage(DispatcherContext.WriteChunkStage.COMMIT_DATA); } if (cmdType == Type.WriteChunk || cmdType == Type.PutSmallFile - || cmdType == Type.PutBlock || cmdType == Type.CreateContainer) { + || cmdType == Type.PutBlock || cmdType == Type.CreateContainer + || cmdType == Type.StreamInit) { builder.setContainer2BCSIDMap(container2BCSIDMap); } CompletableFuture<Message> applyTransactionFuture = --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
