Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: Weichen Xu <[email protected]>
  • Loading branch information
WeichenXu123 committed Oct 11, 2024
1 parent b16d64a commit b0a373b
Showing 1 changed file with 9 additions and 2 deletions.
11 changes: 9 additions & 2 deletions mllib/src/main/scala/org/apache/spark/ml/util/SchemaUtils.scala
Original file line number Diff line number Diff line change
Expand Up @@ -17,14 +17,15 @@

package org.apache.spark.ml.util

import scala.collection.immutable

import org.apache.spark.SparkIllegalArgumentException
import org.apache.spark.ml.attribute._
import org.apache.spark.ml.linalg.VectorUDT
import org.apache.spark.sql.catalyst.util.AttributeNameParser
import org.apache.spark.sql.internal.SQLConf
import org.apache.spark.sql.types._


/**
* Utils for handling schemas.
*/
Expand Down Expand Up @@ -217,7 +218,13 @@ private[spark] object SchemaUtils {
val colSplits = AttributeNameParser.parseAttributeName(colName)
val fieldOpt = schema.findNestedField(colSplits, resolver = SQLConf.get.resolver)
if (fieldOpt.isEmpty) {
throw new SparkIllegalArgumentException("FIELD_NOT_FOUND")
throw new SparkIllegalArgumentException(
errorClass = "FIELD_NOT_FOUND",
messageParameters = immutable.Map(
"fieldName" -> colName,
"fields" -> schema.simpleString
)
)
}
fieldOpt.get._2
}
Expand Down

0 comments on commit b0a373b

Please sign in to comment.