(paimon) branch master updated: [spark] Correct MigrateTableProcedureTest with set target table iterations (#8167)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 68dd708052 [spark] Correct MigrateTableProcedureTest with set target 
table iterations (#8167)
68dd708052 is described below

commit 68dd708052ca6f0046d53b2950f4579a9bfd6694
Author: Arnav Balyan <60175178+arnavbal...@users.noreply.github.com>
AuthorDate: Sat Jun 20 05:44:35 2026 -0700

    [spark] Correct MigrateTableProcedureTest with set target table iterations 
(#8167)
---
 .../paimon/spark/procedure/MigrateTableProcedureTest.scala  | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/MigrateTableProcedureTest.scala
 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/MigrateTableProcedureTest.scala
index dcd832ba0d..1e90bc8955 100644
--- 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/MigrateTableProcedureTest.scala
+++ 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/MigrateTableProcedureTest.scala
@@ -108,23 +108,24 @@ class MigrateTableProcedureTest extends 
PaimonHiveTestBase {
     format => {
       test(
         s"Paimon migrate table procedure: migrate $format non-partitioned 
table with set target table") {
-        withTable(s"hive_tbl_$random", s"target_$random") {
+        withTable(s"hive_tbl_${random}_$format", s"target_${random}_$format") {
           // create hive table
           spark.sql(s"""
-                       |CREATE TABLE hive_tbl_$random (id STRING, name STRING, 
pt STRING)
+                       |CREATE TABLE hive_tbl_${random}_$format (id STRING, 
name STRING, pt STRING)
                        |USING $format
                        |""".stripMargin)
 
-          spark.sql(s"INSERT INTO hive_tbl_$random VALUES ('1', 'a', 'p1'), 
('2', 'b', 'p2')")
+          spark.sql(
+            s"INSERT INTO hive_tbl_${random}_$format VALUES ('1', 'a', 'p1'), 
('2', 'b', 'p2')")
 
           spark.sql(
-            s"CALL sys.migrate_table(source_type => 'hive', table => 
'$hiveDbName.hive_tbl_$random', options => 'file.format=$format', target_table 
=> '$hiveDbName.target_$random', delete_origin => false)")
+            s"CALL sys.migrate_table(source_type => 'hive', table => 
'$hiveDbName.hive_tbl_${random}_$format', options => 'file.format=$format', 
target_table => '$hiveDbName.target_${random}_$format', delete_origin => 
false)")
 
           checkAnswer(
-            spark.sql(s"SELECT * FROM target_$random ORDER BY id"),
+            spark.sql(s"SELECT * FROM target_${random}_$format ORDER BY id"),
             Row("1", "a", "p1") :: Row("2", "b", "p2") :: Nil)
 
-          checkAnswer(spark.sql(s"SELECT * FROM hive_tbl_$random ORDER BY 
id"), Nil)
+          checkAnswer(spark.sql(s"SELECT * FROM hive_tbl_${random}_$format 
ORDER BY id"), Nil)
 
         }
       }