From 36ebdf07dc770dece9ce968b10491c97a46bb468 Mon Sep 17 00:00:00 2001 From: zhengtao Date: Fri, 15 Nov 2024 19:27:09 +0800 Subject: [PATCH] [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 Signed-off-by: SteNicholas --- .../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) } }