We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 54f7a6b commit c7fa518Copy full SHA for c7fa518
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/DFSOutputStream.java
@@ -539,6 +539,9 @@ protected void adjustChunkBoundary() {
539
int psize = 0;
540
if (blockSize == getStreamer().getBytesCurBlock()) {
541
psize = writePacketSize;
542
+ } else if (blockSize - getStreamer().getBytesCurBlock() + PacketHeader.PKT_MAX_HEADER_LEN
543
+ < writePacketSize ) {
544
+ psize = (int)(blockSize - getStreamer().getBytesCurBlock()) + PacketHeader.PKT_MAX_HEADER_LEN;
545
} else {
546
psize = (int) Math
547
.min(blockSize - getStreamer().getBytesCurBlock(), writePacketSize);
0 commit comments