This is an automated email from the ASF dual-hosted git repository. nanda pushed a commit to branch HDDS-2823 in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
commit 3ed29d88202d20873f9f2b7f4e9635ee954bdaf8 Author: Glen Geng <gleng...@tencent.com> AuthorDate: Sat Oct 24 20:58:07 2020 +0530 HDDS-4059. SCMStateMachine::applyTransaction() should not invoke TransactionContext.getClientRequest(). --- .../src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java index b10dd54..ee26e58 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java @@ -54,7 +54,7 @@ public class SCMStateMachine extends BaseStateMachine { new CompletableFuture<>(); try { final SCMRatisRequest request = SCMRatisRequest.decode( - trx.getClientRequest().getMessage()); + Message.valueOf(trx.getStateMachineLogEntry().getLogData())); applyTransactionFuture.complete(process(request)); } catch (Exception ex) { applyTransactionFuture.completeExceptionally(ex); --------------------------------------------------------------------- To unsubscribe, e-mail: ozone-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: ozone-commits-h...@hadoop.apache.org