diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkV2FilterConverter.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkV2FilterConverter.scala index caf6986f1e8e..87a8ddf99381 100644 --- a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkV2FilterConverter.scala +++ b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkV2FilterConverter.scala @@ -112,7 +112,6 @@ case class SparkV2FilterConverter(rowType: RowType) { MultiPredicate.unapply(sparkPredicate) match { case Some((fieldName, literals)) => val index = fieldIndex(fieldName) - literals.map(convertLiteral(index, _)).toList.asJava builder.in(index, literals.map(convertLiteral(index, _)).toList.asJava) case _ => throw new UnsupportedOperationException(s"Convert $sparkPredicate is unsupported.")