(paimon) branch master updated: [test] Add random name to MergeIntoTableTestBase

[lzljs3620320]

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

lzljs3620320 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 c42cb99da6 [test] Add random name to MergeIntoTableTestBase
c42cb99da6 is described below

commit c42cb99da6dfe86acf874ada1064e9fac9161870
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Thu Mar 12 17:00:49 2026 +0800

    [test] Add random name to MergeIntoTableTestBase
---
 .../apache/paimon/spark/sql/MergeIntoTableTestBase.scala | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/MergeIntoTableTestBase.scala
 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/MergeIntoTableTestBase.scala
index 25e996431b..168bedde8f 100644
--- 
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/MergeIntoTableTestBase.scala
+++ 
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/MergeIntoTableTestBase.scala
@@ -23,11 +23,13 @@ import org.apache.paimon.spark.{PaimonAppendTable, 
PaimonPrimaryKeyTable, Paimon
 
 import org.apache.spark.sql.Row
 
+import java.util.UUID
 import java.util.concurrent.Executors
 
 import scala.concurrent.{Await, Future}
 import scala.concurrent.ExecutionContext.Implicits.global
 import scala.concurrent.duration.DurationInt
+import scala.util.Random
 
 abstract class MergeIntoTableTestBase extends PaimonSparkTestBase with 
PaimonTableTest {
 
@@ -790,8 +792,8 @@ trait MergeIntoAppendTableTest extends PaimonSparkTestBase 
with PaimonAppendTabl
 
   test("Paimon MergeInto: concurrent merge and compact") {
     for (dvEnabled <- Seq("true", "false")) {
-      val source = s"mc_s_$dvEnabled"
-      val target = s"mc_t_$dvEnabled"
+      val source = s"mc_s_$dvEnabled" + "_" + createPositiveRandomInt()
+      val target = s"mc_t_$dvEnabled" + "_" + createPositiveRandomInt()
       withTable(source, target) {
         sql(s"CREATE TABLE $source (id INT, b INT, c INT)")
         sql(s"INSERT INTO $source VALUES (1, 1, 1)")
@@ -841,8 +843,8 @@ trait MergeIntoAppendTableTest extends PaimonSparkTestBase 
with PaimonAppendTabl
 
   test("Paimon MergeInto: concurrent two merge") {
     for (dvEnabled <- Seq("true", "false")) {
-      val source = s"tm_s_$dvEnabled"
-      val target = s"tm_t_$dvEnabled"
+      val source = s"tm_s_$dvEnabled" + "_" + createPositiveRandomInt()
+      val target = s"tm_t_$dvEnabled" + "_" + createPositiveRandomInt()
       withTable(source, target) {
         sql(s"CREATE TABLE $source (id INT, b INT, c INT)")
         sql(
@@ -889,4 +891,10 @@ trait MergeIntoAppendTableTest extends PaimonSparkTestBase 
with PaimonAppendTabl
       }
     }
   }
+
+  def createPositiveRandomInt(): Int = {
+    val random = new Random()
+    val positiveInt = random.nextInt()
+    if (positiveInt > 0) positiveInt else -positiveInt
+  }
 }