diff --git a/jvm-packages/xgboost4j-spark/src/main/scala/ml/dmlc/xgboost4j/scala/spark/rapids/GpuXGBoost.scala b/jvm-packages/xgboost4j-spark/src/main/scala/ml/dmlc/xgboost4j/scala/spark/rapids/GpuXGBoost.scala index cea13cd075b2..4588d2226079 100644 --- a/jvm-packages/xgboost4j-spark/src/main/scala/ml/dmlc/xgboost4j/scala/spark/rapids/GpuXGBoost.scala +++ b/jvm-packages/xgboost4j-spark/src/main/scala/ml/dmlc/xgboost4j/scala/spark/rapids/GpuXGBoost.scala @@ -380,7 +380,7 @@ private[spark] object GpuXGBoost { .groupBy(groupName) .agg(collect_list(struct(schema.fieldNames.map(col): _*)) as "list") - implicit val encoder = RowEncoder(schema) + implicit val encoder = RowEncoder.encoderFor(schema) // Expand the grouped rows after repartition groupedDF.repartition(nWorkers).mapPartitions(iter => { new Iterator[Row] {