فهرست منبع

HDDS-1320. Update ozone to latest ratis snapshot build (0.4.0-1fc5ace-SNAPSHOT). Contributed by Mukul Kumar Singh.

Arpit Agarwal 6 سال پیش
والد
کامیت
90afc9ab03

+ 2 - 1
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java

@@ -495,7 +495,8 @@ public final class XceiverServerRatis extends XceiverServer {
       RaftClientRequest.Type type) {
     return new RaftClientRequest(clientId, server.getId(),
         RaftGroupId.valueOf(PipelineID.getFromProtobuf(pipelineID).getId()),
-        nextCallId(), 0, Message.valueOf(request.toByteString()), type);
+        nextCallId(), Message.valueOf(request.toByteString()), type,
+        null);
   }
 
   private void handlePipelineFailure(RaftGroupId groupId,

+ 1 - 1
hadoop-hdds/pom.xml

@@ -46,7 +46,7 @@ http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <hdds.version>0.5.0-SNAPSHOT</hdds.version>
 
     <!-- Apache Ratis version -->
-    <ratis.version>0.4.0-5680cf5-SNAPSHOT</ratis.version>
+    <ratis.version>0.4.0-1fc5ace-SNAPSHOT</ratis.version>
 
     <bouncycastle.version>1.60</bouncycastle.version>
 

+ 4 - 4
hadoop-ozone/ozone-manager/src/test/java/org/apache/hadoop/ozone/om/ratis/TestOzoneManagerStateMachine.java

@@ -134,11 +134,11 @@ public class TestOzoneManagerStateMachine {
 
     RaftClientRequest raftClientRequest =
         new RaftClientRequest(ClientId.randomId(),
-            RaftPeerId.valueOf("random"), raftGroupId, 1, 1,
+            RaftPeerId.valueOf("random"), raftGroupId, 1,
             Message.valueOf(
                 OMRatisHelper.convertRequestToByteString(omRequest)),
             RaftClientRequest.Type.valueOf(
-                RaftProtos.WriteRequestTypeProto.getDefaultInstance()));
+                RaftProtos.WriteRequestTypeProto.getDefaultInstance()), null);
 
     TransactionContext transactionContext =
         ozoneManagerStateMachine.startTransaction(raftClientRequest);
@@ -232,11 +232,11 @@ public class TestOzoneManagerStateMachine {
 
     RaftClientRequest raftClientRequest =
         new RaftClientRequest(ClientId.randomId(),
-            RaftPeerId.valueOf("random"), raftGroupId, 1, 1,
+            RaftPeerId.valueOf("random"), raftGroupId, 1,
             Message.valueOf(
                 OMRatisHelper.convertRequestToByteString(omRequest)),
             RaftClientRequest.Type.valueOf(
-                RaftProtos.WriteRequestTypeProto.getDefaultInstance()));
+                RaftProtos.WriteRequestTypeProto.getDefaultInstance()), null);
 
     TransactionContext transactionContext =
         ozoneManagerStateMachine.startTransaction(raftClientRequest);

+ 1 - 1
hadoop-ozone/pom.xml

@@ -29,7 +29,7 @@
     <hadoop.version>3.2.0</hadoop.version>
     <hdds.version>0.5.0-SNAPSHOT</hdds.version>
     <ozone.version>0.5.0-SNAPSHOT</ozone.version>
-    <ratis.version>0.4.0-5680cf5-SNAPSHOT</ratis.version>
+    <ratis.version>0.4.0-1fc5ace-SNAPSHOT</ratis.version>
     <bouncycastle.version>1.60</bouncycastle.version>
     <ozone.release>Crater Lake</ozone.release>
     <declared.ozone.version>${ozone.version}</declared.ozone.version>