This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new c03273aa83 HDDS-8696. Ozone Streaming support block token (#4780)
c03273aa83 is described below
commit c03273aa83a52322dd526923e0dd7b6e044d527d
Author: hao guo <[email protected]>
AuthorDate: Tue Jun 6 23:17:19 2023 +0800
HDDS-8696. Ozone Streaming support block token (#4780)
---
.../org/apache/hadoop/hdds/scm/storage/BlockDataStreamOutput.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockDataStreamOutput.java
b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockDataStreamOutput.java
index d19f2aea13..611ce809d7 100644
---
a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockDataStreamOutput.java
+++
b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockDataStreamOutput.java
@@ -205,6 +205,10 @@ public class BlockDataStreamOutput implements
ByteBufferStreamOutput {
.setContainerID(blockID.get().getContainerID())
.setDatanodeUuid(id).setWriteChunk(writeChunkRequest);
+ if (token != null) {
+ builder.setEncodedToken(token.encodeToUrlString());
+ }
+
ContainerCommandRequestMessage message =
ContainerCommandRequestMessage.toMessage(builder.build(), null);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
