diff --git a/connector/connect/server/src/test/scala/org/apache/spark/sql/connect/dsl/package.scala b/connector/connect/server/src/test/scala/org/apache/spark/sql/connect/dsl/package.scala index da9a0865b8ca6..b50c04e7540f5 100644 --- a/connector/connect/server/src/test/scala/org/apache/spark/sql/connect/dsl/package.scala +++ b/connector/connect/server/src/test/scala/org/apache/spark/sql/connect/dsl/package.scala @@ -1019,7 +1019,13 @@ package object dsl { WithColumnsRenamed .newBuilder() .setInput(logicalPlan) - .putAllRenameColumnsMap(renameColumnsMap.asJava)) + .addAllRenames(renameColumnsMap.toSeq.map { case (k, v) => + WithColumnsRenamed.Rename + .newBuilder() + .setColName(k) + .setNewColName(v) + .build() + }.asJava)) .build() }