From 60bf394c9a7ddd80dc15f1b0446015d390c5a831 Mon Sep 17 00:00:00 2001
From: Sreesh Maheshwar <maheshwarsreesh@gmail.com>
Date: Tue, 20 Jan 2026 10:52:11 +0000
Subject: [PATCH] [Test] REST concurrent replace V3 failure

---
 .../java/org/apache/iceberg/catalog/CatalogTests.java | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java b/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java
index 833b2fb0b46f..7a86bf020a59 100644
--- a/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java
+++ b/core/src/test/java/org/apache/iceberg/catalog/CatalogTests.java
@@ -2655,15 +2655,20 @@ public void testReplaceTableKeepsSnapshotLog() {
         .containsExactly(snapshotBeforeReplace, snapshotAfterReplace);
   }
 
-  @Test
-  public void testConcurrentReplaceTransactions() {
+  @ParameterizedTest
+  @ValueSource(ints = {2, 3})
+  public void testConcurrentReplaceTransactions(int formatVersion) {
     C catalog = catalog();
 
     if (requiresNamespaceCreate()) {
       catalog.createNamespace(NS);
     }
 
-    Transaction transaction = catalog.buildTable(TABLE, SCHEMA).createTransaction();
+    Transaction transaction =
+        catalog
+            .buildTable(TABLE, SCHEMA)
+            .withProperty("format-version", String.valueOf(formatVersion))
+            .createTransaction();
     transaction.newFastAppend().appendFile(FILE_A).commit();
     transaction.commitTransaction();