fix comment

apache · Apr 12, 2023 · d198fb5 · d198fb5
1 parent 5fab041
commit d198fb5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...nt-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java b/...nt-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java
@@ -158,8 +158,8 @@ private int uncompress(CompressedShuffleBlock rawBlock, ByteBuffer rawData) {
       unCompressedBytesLength += uncompressedLen;
       long decompressDuration = System.currentTimeMillis() - startDecompress;
       decompressTime += decompressDuration;
-      // ByteBuffer's limit may not uncompressDataLength after using compress method.
-      // So we need set limit here.
+      // uncompressedData's limit is not updated by `codec.decompress`, however this information is used
+      // by `createKVIterator`. Update limit here.
       uncompressedData.limit(uncompressedData.position() + uncompressedLen);
     } else {
       uncompressedData = rawData;