diff --git a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RollbackProcedureTest.scala b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RollbackProcedureTest.scala index 54c2a52b20d3..fcae7c2dee94 100644 --- a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RollbackProcedureTest.scala +++ b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RollbackProcedureTest.scala @@ -39,7 +39,7 @@ class RollbackProcedureTest extends PaimonSparkTestBase with StreamTest { |TBLPROPERTIES ('primary-key'='a', 'bucket'='3') |""".stripMargin) val location = loadTable("T").location().toString - + val inputData = MemoryStream[(Int, String)] val stream = inputData .toDS()