Change to reuse index

apache · Sep 8, 2020 · db665a1 · db665a1
1 parent 1fd826b
commit db665a1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/resource/ResourceUtils.scala b/core/src/main/scala/org/apache/spark/resource/ResourceUtils.scala
@@ -149,11 +149,12 @@ private[spark] object ResourceUtils extends Logging {
 
   def listResourceIds(sparkConf: SparkConf, componentName: String): Seq[ResourceID] = {
     sparkConf.getAllWithPrefix(s"$componentName.$RESOURCE_PREFIX.").map { case (key, _) =>
-      if (key.indexOf('.') < 0) {
+      val index = key.indexOf('.')
+      if (index < 0) {
         throw new SparkException(s"You must specify an amount config for resource: $key " +
           s"config: $componentName.$RESOURCE_PREFIX.$key")
       }
-      key.substring(0, key.indexOf('.'))
+      key.substring(0, index)
     }.distinct.map(name => new ResourceID(componentName, name))
   }