Skip to content

Commit 356f8cc

Browse files
committed
replace break
1 parent 65790fc commit 356f8cc

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@ import java.lang
2121
import java.util.{Map => JMap}
2222
import java.util.concurrent.{ConcurrentHashMap, ScheduledExecutorService, TimeUnit}
2323

24-
import scala.collection.{breakOut, mutable}
2524
import scala.collection.JavaConverters._
25+
import scala.collection.mutable
2626
import scala.collection.mutable.ArrayBuffer
2727
import scala.util.Random
2828

@@ -512,8 +512,7 @@ abstract class AbstractSource(conf: CelebornConf, role: String)
512512
}
513513
var addNum = 0
514514
val appCount0Metrics = ArrayBuffer[String]()
515-
for (m <- metricList) {
516-
if (addNum >= leftNum) breakOut
515+
for (m <- metricList if addNum < leftNum) {
517516
var strMetrics = ""
518517
var isApp = false
519518
m match {

0 commit comments

Comments
 (0)