diff --git a/connector/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala b/connector/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala index 5b4567aa2881f..cee0d9a3dd726 100644 --- a/connector/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala +++ b/connector/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala @@ -1789,7 +1789,7 @@ class KafkaMicroBatchV2SourceSuite extends KafkaMicroBatchSourceSuiteBase { CheckAnswer(data: _*), Execute { query => // The rate limit is 1, so there must be some delay in offsets per partition. - val progressWithDelay = query.recentProgress.map(_.sources.head).reverse.find { progress => + val progressWithDelay = query.recentProgress.map(_.sources.head).findLast { progress => // find the metrics that has non-zero average offsetsBehindLatest greater than 0. !progress.metrics.isEmpty && progress.metrics.get("avgOffsetsBehindLatest").toDouble > 0 } diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala index 09f6c5344546a..dfd4cefb542de 100644 --- a/core/src/main/scala/org/apache/spark/util/Utils.scala +++ b/core/src/main/scala/org/apache/spark/util/Utils.scala @@ -2852,7 +2852,7 @@ private[spark] object Utils else { // The last char is a dollar sign // Find last non-dollar char - val lastNonDollarChar = s.reverse.find(_ != '$') + val lastNonDollarChar = s.findLast(_ != '$') lastNonDollarChar match { case None => s case Some(c) =>