apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-1717] Fix ReusedExchangedSuit UT bug

Browse Source 
### 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 <shuaizhentao.szt@alibaba-inc.com>
Signed-off-by: SteNicholas <programgeek@163.com>
This commit is contained in:
zhengtao 2024-11-15 19:27:09 +08:00 committed by SteNicholas
parent 11a4007965
commit 36ebdf07dc
No known key found for this signature in database
GPG Key ID: 1FC79E01BA3B84D5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala
View File

@ -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)
}
}