fix

zuston · Dec 15, 2023 · 1f8d253 · 1f8d253
1 parent bacd33b
commit 1f8d253
Showing 1 changed file with 1 addition and 9 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
@@ -151,15 +151,7 @@ public boolean hasNext() {
  }
 
  private boolean isSameMemoryType(ByteBuffer left, ByteBuffer right) {
- if (left.isDirect() && right.isDirect()) {
- return true;
- }
-
- if (!left.isDirect() && !right.isDirect()) {
- return true;
- }
-
- return false;
+ return left.isDirect() == right.isDirect();
  }
 
  private int uncompress(CompressedShuffleBlock rawBlock, ByteBuffer rawData) {