fixup

IBM · Jul 14, 2023 · 1c4af44 · 1c4af44
1 parent 700cefe
commit 1c4af44
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/org/apache/spark/shuffle/sort/S3ShuffleManager.scala b/src/main/scala/org/apache/spark/shuffle/sort/S3ShuffleManager.scala
@@ -167,7 +167,7 @@ private[spark] class S3ShuffleManager(conf: SparkConf) extends ShuffleManager wi
 
   /** Shut down this ShuffleManager. */
   override def stop(): Unit = {
-    val cleanupRequired = registeredShuffleIds.size
+    val cleanupRequired = registeredShuffleIds.nonEmpty
     registeredShuffleIds.foreach(
       shuffleId => {
         purgeCaches(shuffleId)