You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by na...@apache.org on 2020/10/25 17:23:49 UTC
[hadoop-ozone] 03/11: HDDS-4059.
SCMStateMachine::applyTransaction() should not invoke
TransactionContext.getClientRequest().
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 <gl...@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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: ozone-commits-help@hadoop.apache.org