This is an automated email from the ASF dual-hosted git repository. captainzmc pushed a commit to branch HDDS-4454 in repository https://gitbox.apache.org/repos/asf/ozone.git
commit 72e1e02db8bb96ed84d4d4ccd84355d3343b5607 Author: Sadanand Shenoy <[email protected]> AuthorDate: Fri Jan 14 20:12:13 2022 +0530 HDDS-6178. [Ozone-Streaming] Fix NPE in HDDS-6139. (#2984) --- .../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 6ef59dd6d8..ec925d1e6a 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 @@ -343,6 +343,10 @@ public class BlockDataStreamOutput implements ByteBufferStreamOutput { while (len > 0) { final StreamBuffer buf = bufferList.get(count); final long writeLen = Math.min(buf.position(), len); + if (buffersForPutBlock == null) { + buffersForPutBlock = new ArrayList<>(); + } + buffersForPutBlock.add(buf); final ByteBuffer duplicated = buf.duplicate(); duplicated.position(0); duplicated.limit(buf.position()); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
