diff --git a/integration-test/spark3/src/test/java/org/apache/uniffle/test/GetShuffleReportForMultiPartTest.java b/integration-test/spark3/src/test/java/org/apache/uniffle/test/GetShuffleReportForMultiPartTest.java index f719c96d26..899970ce34 100644 --- a/integration-test/spark3/src/test/java/org/apache/uniffle/test/GetShuffleReportForMultiPartTest.java +++ b/integration-test/spark3/src/test/java/org/apache/uniffle/test/GetShuffleReportForMultiPartTest.java @@ -175,7 +175,8 @@ public int compare(String o1, String o2) { i++; } SparkConf conf = spark.sparkContext().conf(); - if (!conf.get("spark.shuffle.manager", "").isEmpty()) { + if (conf.get("spark.shuffle.manager", "") + .equals("org.apache.uniffle.test.GetShuffleReportForMultiPartTest$RssShuffleManagerWrapper")) { RssShuffleManagerWrapper mockRssShuffleManager = (RssShuffleManagerWrapper) spark.sparkContext().env().shuffleManager(); int expectRequestNum = mockRssShuffleManager.getShuffleIdToPartitionNum().values().stream()