This is an automated email from the ASF dual-hosted git repository. szetszwo pushed a commit to branch HDDS-4454 in repository https://gitbox.apache.org/repos/asf/ozone.git
commit 33c0260ab500e956412c24e28161f3e197eb8b2d Author: Sadanand Shenoy <[email protected]> AuthorDate: Fri Jan 14 20:12:13 2022 +0530 HDDS-6178. [Ozone-Streaming] Fix NPE in HDDS-6139. (#2984) (cherry picked from commit 72e1e02db8bb96ed84d4d4ccd84355d3343b5607) (cherry picked from commit 151ee53cd71442a272688840d0a5bfc01816aa11) --- .../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]
