todo

apache · Nov 11, 2024 · 41fba8d · 41fba8d
1 parent 5d628b9
commit 41fba8d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...park/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala b/...park/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala
@@ -261,7 +261,7 @@ class CelebornShuffleReader[K, C](
       if (handle.numMappers > 0) {
         val startFetchWait = System.nanoTime()
         var inputStream: CelebornInputStream = streams.get(partitionId)
-        // todo bug fix:  split后，fetch时inputStream一直为空
+        // todo bug fix:  inputStream keep null when revive happened
         while (inputStream == null) {
           if (exceptionRef.get() != null) {
             exceptionRef.get() match {