This is an automated email from the ASF dual-hosted git repository.
nicholasjiang pushed a commit to branch branch-0.5
in repository https://gitbox.apache.org/repos/asf/celeborn.git
The following commit(s) were added to refs/heads/branch-0.5 by this push:
new f3a1b6ff9 [CELEBORN-1717] Fix ReusedExchangedSuit UT bug
f3a1b6ff9 is described below
commit f3a1b6ff95b306257f72abb349bb7159d2332baa
Author: zhengtao <[email protected]>
AuthorDate: Fri Nov 15 19:27:09 2024 +0800
[CELEBORN-1717] Fix ReusedExchangedSuit UT bug
### What changes were proposed in this pull request?
The UT should test both ture and false condition
### Why are the changes needed?
### Does this PR introduce _any_ user-facing change?
### How was this patch tested?
exiting UT
Closes #2914 from zaynt4606/cmt-clb1717.
Authored-by: zhengtao <[email protected]>
Signed-off-by: SteNicholas <[email protected]>
(cherry picked from commit 36ebdf07dc770dece9ce968b10491c97a46bb468)
Signed-off-by: SteNicholas <[email protected]>
---
.../scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala
b/tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala
index aa98c3832..b5c7d2932 100644
---
a/tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala
+++
b/tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala
@@ -37,14 +37,14 @@ class ReusedExchangeSuite extends AnyFunSuite
Array(true, false).foreach { chunkPrefetch =>
test(s"[CELEBORN-980] Asynchronously delete original files" +
s"to fix ReusedExchange bug, chunkPrefetch: $chunkPrefetch") {
- testReusedExchange(false, false)
+ testReusedExchange(false, chunkPrefetch)
}
}
Array(true, false).foreach { chunkPrefetch =>
test("[CELEBORN-1177] OpenStream should register stream via
ChunkStreamManager" +
s"to close stream for ReusedExchange, chunkPrefetch: $chunkPrefetch") {
- testReusedExchange(true, false)
+ testReusedExchange(true, chunkPrefetch)
}
}
