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"));
}
};