[Improvement] Quickly delete local or HDFS data at the shuffleId level.

apache · Sep 9, 2024 · 0af2052 · 0af2052
1 parent 3ecbb79
commit 0af2052
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/integration-test/common/src/test/java/org/apache/uniffle/test/RpcClientRetryTest.java b/integration-test/common/src/test/java/org/apache/uniffle/test/RpcClientRetryTest.java
@@ -83,6 +83,7 @@ public static MockedShuffleServer createMockedShuffleServer(int id, File tmpDir)
     shuffleServerConf.setString("rss.storage.basePath", basePath);
     shuffleServerConf.set(ShuffleServerConf.SERVER_MEMORY_SHUFFLE_LOWWATERMARK_PERCENTAGE, 5.0);
     shuffleServerConf.set(ShuffleServerConf.SERVER_MEMORY_SHUFFLE_HIGHWATERMARK_PERCENTAGE, 10.0);
+    shuffleServerConf.set(ShuffleServerConf.SINGLE_BUFFER_FLUSH_BLOCKS_NUM_THRESHOLD, 1);
     shuffleServerConf.set(ShuffleServerConf.SERVER_BUFFER_CAPACITY, 600L);
     return new MockedShuffleServer(shuffleServerConf);
   }