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 7be7b5d25de IGNITE-27839 Fix assignments might have not updated (#7586)
7be7b5d25de is described below
commit 7be7b5d25de90876fe346376f0c14b0866dae85c
Author: Cyrill <[email protected]>
AuthorDate: Wed Feb 18 11:39:31 2026 +0300
IGNITE-27839 Fix assignments might have not updated (#7586)
Co-authored-by: Kirill Sizov <[email protected]>
---
.../disaster/ItDisasterRecoveryResetPartitionsTest.java | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
diff --git
a/modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoveryResetPartitionsTest.java
b/modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoveryResetPartitionsTest.java
index 39a4facf529..7ccacde64d2 100644
---
a/modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoveryResetPartitionsTest.java
+++
b/modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoveryResetPartitionsTest.java
@@ -80,7 +80,17 @@ public class ItDisasterRecoveryResetPartitionsTest extends
ClusterPerTestIntegra
assertTrue(waitForCondition(() ->
!hasAssignmentsForNode(DEFAULT_ZONE_NAME, nodeToStop), 10000));
- assertDoesNotThrow(() -> executeSql(selectSql));
+ // SQL engine reads assignments from AssignmentsTracker that is
updated asynchronously
+ // via metastorage watch events. The waitForCondition above verifies
metastorage state directly, but there is
+ // a propagation delay before the watch event updates the cache. Retry
the query to tolerate this lag.
+ assertTrue(waitForCondition(() -> {
+ try {
+ executeSql(selectSql);
+ return true;
+ } catch (SqlException e) {
+ return false;
+ }
+ }, 10_000), "SQL query should succeed after partition reset");
}
private boolean hasAssignmentsForNode(String zoneName, String nodeName) {
