advancedxy commented on code in PR #693:
URL: https://github.com/apache/incubator-uniffle/pull/693#discussion_r1146009921
##########
client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java:
##########
@@ -101,7 +101,8 @@ public boolean hasNext() {
// read next segment
long startFetch = System.currentTimeMillis();
// depends on spark.shuffle.compress, shuffled block may not be
compressed
- CompressedShuffleBlock rawBlock =
shuffleReadClient.readShuffleBlockData();
+ CompressedShuffleBlock rawBlock = null;
Review Comment:
This is not intentional.. This change is introduced during a code refactor.
let me remove it in a following commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
