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

Reply via email to