File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -539,13 +539,14 @@ protected void adjustChunkBoundary() {
539539 int psize = 0 ;
540540 if (blockSize == getStreamer ().getBytesCurBlock ()) {
541541 psize = writePacketSize ;
542- } else if (blockSize - getStreamer ().getBytesCurBlock () + PacketHeader .PKT_MAX_HEADER_LEN
543- < writePacketSize ) {
544- psize = (int )(blockSize - getStreamer ().getBytesCurBlock ()) +
545- PacketHeader .PKT_MAX_HEADER_LEN ;
546542 } else {
547543 psize = (int ) Math
548544 .min (blockSize - getStreamer ().getBytesCurBlock (), writePacketSize );
545+ if (psize < writePacketSize ) {
546+ final int chunkSize = bytesPerChecksum + getChecksumSize ();
547+ int numPackets = (psize + bytesPerChecksum - 1 ) / bytesPerChecksum ;
548+ psize = PacketHeader .PKT_MAX_HEADER_LEN + numPackets * chunkSize ;
549+ }
549550 }
550551 computePacketChunkSize (psize , bytesPerChecksum );
551552 }
You can’t perform that action at this time.
0 commit comments