diff --git a/mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala b/mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala index d371da762c55..c420db5ed6cc 100644 --- a/mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala +++ b/mllib/src/main/scala/org/apache/spark/ml/feature/VectorIndexer.scala @@ -414,7 +414,11 @@ class VectorIndexerModel private[ml] ( featAttr } case (origAttr: Attribute, featAttr: NumericAttribute) => - origAttr.withIndex(featAttr.index.get) + if (origAttr.name.nonEmpty) { + featAttr.withName(origAttr.name.get) + } else { + featAttr + } case (origAttr: Attribute, _) => origAttr }