(ignite) branch master updated: IGNITE-28706 Fix TxWithExceptionalInterceptorTest.testTxWithExceptionInterceptor fails (#13162)

[zstan]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 13ba04846ce IGNITE-28706 Fix 
TxWithExceptionalInterceptorTest.testTxWithExceptionInterceptor fails (#13162)
13ba04846ce is described below

commit 13ba04846ce67e840d962cea34b2770b9d77c535
Author: Evgeniy Stanilovskiy <stanilov...@gmail.com>
AuthorDate: Thu May 21 12:32:44 2026 +0300

    IGNITE-28706 Fix 
TxWithExceptionalInterceptorTest.testTxWithExceptionInterceptor fails (#13162)
---
 .../processors/tx/TxWithExceptionalInterceptorTest.java  | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/tx/TxWithExceptionalInterceptorTest.java
 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/tx/TxWithExceptionalInterceptorTest.java
index 2c824f64fa9..c26425ec906 100644
--- 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/tx/TxWithExceptionalInterceptorTest.java
+++ 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/tx/TxWithExceptionalInterceptorTest.java
@@ -305,7 +305,7 @@ public class TxWithExceptionalInterceptorTest extends 
GridCommonAbstractTest {
         IgniteCache<Integer, Integer> commonCache = 
txNode.cache(COMMON_CACHE_NAME);
 
         Integer primaryKey = primaryKeyCoordAware(PROC_CACHE_NAME);
-        Integer primaryKeyCommon = primaryKeyCoordAware(PROC_CACHE_NAME);
+        Integer primaryKeyCommon = primaryKeyCoordAware(COMMON_CACHE_NAME);
 
         try (Transaction tx = txNode.transactions().txStart()) {
             processedCache.put(primaryKey, 1);
@@ -325,18 +325,22 @@ public class TxWithExceptionalInterceptorTest extends 
GridCommonAbstractTest {
 
         // 2 server nodes + 1 thick client
         if ((txCoord == TxCoordNodeRole.BACKUP || txCoord == 
TxCoordNodeRole.PRIMARY) ||
-            !writeThrough && txCoord == TxCoordNodeRole.THICK_CLIENT)
+            !writeThrough && txCoord == TxCoordNodeRole.THICK_CLIENT) {
             waitForTopology(3);
 
+            // Topology can change but affinity change is still in progress, 
thus sql operations can be mapped erroneously.
+            awaitPartitionMapExchange();
+        }
+
         checkExceptionRaised();
 
-        // external storage stored result
+        // External storage stored result.
         Object storeVal = null;
 
         if (writeThrough)
             storeVal = strategy.getFromStore(primaryKey);
 
-        // Processed cache kv result
+        // Processed cache kv result.
         Object kvVal = null;
 
         List<Ignite> grids = new ArrayList<>(G.allGrids());
@@ -347,7 +351,7 @@ public class TxWithExceptionalInterceptorTest extends 
GridCommonAbstractTest {
             }
         });
 
-        // client first
+        // Client first.
         assertTrue(grids.get(0).name().contains(CLIENT_NAME));
 
         for (Ignite node : grids) {
@@ -363,7 +367,7 @@ public class TxWithExceptionalInterceptorTest extends 
GridCommonAbstractTest {
                 continue;
             }
 
-            // obtain sql results first, kv api can eventually recover 
results, thus for more clear test - let`s check sql first
+            // Obtain sql results first, kv api can eventually recover 
results, thus for more clear test - let`s check sql first.
             Object sqlVal = getSqlResultByKey(node, PROC_CACHE_NAME, 
primaryKey, false);
 
             if (kvVal == null)