optimize

zuston · Dec 13, 2023 · bacd33b · bacd33b
1 parent 29fd1d9
commit bacd33b
Showing 1 changed file with 11 additions and 0 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
@@ -172,6 +172,17 @@ private int uncompress(CompressedShuffleBlock rawBlock, ByteBuffer rawData) {
  if (uncompressedData == null
  || uncompressedData.capacity() < uncompressedLen
  || !isSameMemoryType(uncompressedData, rawData)) {
+
+ if (LOG.isDebugEnabled()) {
+ if (!isSameMemoryType(uncompressedData, rawData)) {
+ LOG.debug(
+ "This should not happen that the temporary uncompressed data's memory type(isDirect:{}) "
+ + "is not same with fetched data buffer(isDirect:{})",
+ uncompressedData.isDirect(),
+ rawData.isDirect());
+ }
+ }
+
  if (uncompressedData != null) {
  RssUtils.releaseByteBuffer(uncompressedData);
  }