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

sk0x50 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new e100a52c355 IGNITE-27277 ItTableScanTest#testPhantomReads is flaky due 
to bad transactionException handling (#7182)
e100a52c355 is described below

commit e100a52c355811a179ca12ae7b1cf41a213f7dc1
Author: Mikhail Efremov <[email protected]>
AuthorDate: Tue Dec 9 16:36:46 2025 +0600

    IGNITE-27277 ItTableScanTest#testPhantomReads is flaky due to bad 
transactionException handling (#7182)
---
 .../java/org/apache/ignite/internal/table/ItTableScanTest.java       | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTableScanTest.java
 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTableScanTest.java
index 83b85c02f6e..0837fbaf231 100644
--- 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTableScanTest.java
+++ 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItTableScanTest.java
@@ -79,6 +79,7 @@ import 
org.apache.ignite.internal.storage.impl.TestMvPartitionStorage;
 import org.apache.ignite.internal.storage.index.impl.TestSortedIndexStorage;
 import org.apache.ignite.internal.testframework.IgniteTestUtils;
 import org.apache.ignite.internal.tx.InternalTransaction;
+import org.apache.ignite.internal.tx.LockException;
 import org.apache.ignite.internal.tx.PendingTxPartitionEnlistment;
 import org.apache.ignite.internal.tx.PossibleDeadlockOnLockAcquireException;
 import org.apache.ignite.lang.ErrorGroups.Transactions;
@@ -694,7 +695,9 @@ public class ItTableScanTest extends BaseSqlIntegrationTest 
{
                                 Tuple.create().set("valInt", 
intValue).set("valStr", "Str_" + intValue));
                     } catch (TransactionException e) {
                         // May happen, this is a race after all.
-                        assertThat(e.getMessage(), containsString("Failed to 
acquire a lock"));
+                        Throwable rootCause = unwrapRootCause(e);
+                        assertInstanceOf(LockException.class, rootCause);
+                        assertThat(rootCause.getMessage(), 
containsString("Failed to acquire a lock"));
                     }
                 };
 

Reply via email to