(ignite) branch master updated: IGNITE-28674 Fix flaky SqlPartitionEvictionTest.testSqlConsistencyOnEviction - Fixes #13134.

[alexpl]

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

asf-gitbox-commits 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 6b9ea381a53 IGNITE-28674 Fix flaky 
SqlPartitionEvictionTest.testSqlConsistencyOnEviction - Fixes #13134.
6b9ea381a53 is described below

commit 6b9ea381a5371add6691597037d73ff9644be003
Author: Aleksey Plekhanov <plehanov.a...@gmail.com>
AuthorDate: Wed May 20 17:47:07 2026 +0300

    IGNITE-28674 Fix flaky 
SqlPartitionEvictionTest.testSqlConsistencyOnEviction - Fixes #13134.
    
    Signed-off-by: Aleksey Plekhanov <plehanov.a...@gmail.com>
---
 docs/_docs/data-streaming.adoc                                    | 2 +-
 .../ignite/internal/processors/datastreamer/DataStreamerImpl.java | 2 +-
 .../internal/processors/cache/index/SqlPartitionEvictionTest.java | 8 +++++++-
 3 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/docs/_docs/data-streaming.adoc b/docs/_docs/data-streaming.adoc
index c39afe3632a..ea6664ae86b 100644
--- a/docs/_docs/data-streaming.adoc
+++ b/docs/_docs/data-streaming.adoc
@@ -68,7 +68,7 @@ DataStreamer doesn't guarantee:
 If <<overwriting, 'allowOverwrite'>> property is 'false' (default), consider:
 []
 - You should not have the same keys repeating in the data being streamed;
-- Streamer cancelation or streamer node failure can cause data inconsistency;
+- Streamer cancelation or topology change can cause data inconsistency;
 - If loading into a persistent cache, concurrently created snapshot may 
contain inconsistent data and might not be restored entirely.
 
 Most important behavior of Ignite Data Streamer is defined by <<receivers, 
stream receiver>> and
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index a86b6240ed0..f8248e40f70 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -134,7 +134,7 @@ public class DataStreamerImpl<K, V> implements 
IgniteDataStreamer<K, V>, Delayed
     /** */
     public static final String WRN_INCONSISTENT_UPDATES = "The Data Streamer 
loads data with 'allowOverwrite' set " +
         "to false. It doesn't guarantee data consistency until successfully 
finishes. Streamer cancelation or " +
-        "streamer node failure can cause data inconsistency. Concurrently 
created snapshot may contain inconsistent " +
+        "topology change can cause data inconsistency. Concurrently created 
snapshot may contain inconsistent " +
         "data and might not be restored entirely.";
 
     /** Per thread buffer size. */
diff --git 
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SqlPartitionEvictionTest.java
 
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SqlPartitionEvictionTest.java
index 9b7a94cbc46..a399a79fd6d 100644
--- 
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SqlPartitionEvictionTest.java
+++ 
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SqlPartitionEvictionTest.java
@@ -100,7 +100,7 @@ public class SqlPartitionEvictionTest extends 
GridCommonAbstractTest {
     /**
      * For awaiting of eviction start.
      */
-    private static final CountDownLatch LATCH = new CountDownLatch(1);
+    private static CountDownLatch LATCH;
 
     /** {@inheritDoc} */
     @Override protected IgniteConfiguration getConfiguration(String 
igniteInstanceName) throws Exception {
@@ -138,8 +138,14 @@ public class SqlPartitionEvictionTest extends 
GridCommonAbstractTest {
         while (idx <= backupsCount)
             ig = ignitionStart(idx++);
 
+        awaitPartitionMapExchange();
+
         loadData(ig, 0, NUM_ENTITIES);
 
+        assertEquals(NUM_ENTITIES, ig.cache(POI_CACHE_NAME).size());
+
+        LATCH = new CountDownLatch(1);
+
         ignitionStart(idx);
 
         awaitPartitionMapExchange();