(ignite-3) branch main updated: IGNITE-24633 Fix ItTxResourcesVacuumTest.testVacuum (#5413)

[sanpwc]

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

sanpwc 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 c42912508a5 IGNITE-24633 Fix ItTxResourcesVacuumTest.testVacuum (#5413)
c42912508a5 is described below

commit c42912508a594bbd507f6b89f46e4ec7ec982f90
Author: Alexander Lapin <lapin1...@gmail.com>
AuthorDate: Fri Mar 14 18:41:39 2025 +0200

    IGNITE-24633 Fix ItTxResourcesVacuumTest.testVacuum (#5413)
---
 .../org/apache/ignite/tx/distributed/ItTxResourcesVacuumTest.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/modules/transactions/src/integrationTest/java/org/apache/ignite/tx/distributed/ItTxResourcesVacuumTest.java
 
b/modules/transactions/src/integrationTest/java/org/apache/ignite/tx/distributed/ItTxResourcesVacuumTest.java
index a4a25d5269e..f5aabc30caf 100644
--- 
a/modules/transactions/src/integrationTest/java/org/apache/ignite/tx/distributed/ItTxResourcesVacuumTest.java
+++ 
b/modules/transactions/src/integrationTest/java/org/apache/ignite/tx/distributed/ItTxResourcesVacuumTest.java
@@ -79,7 +79,6 @@ import org.apache.ignite.tx.TransactionOptions;
 import org.jetbrains.annotations.Nullable;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 
@@ -180,7 +179,6 @@ public class ItTxResourcesVacuumTest extends 
ClusterPerTestIntegrationTest {
      * </ul>
      */
     @Test
-    @Disabled("https://issues.apache.org/jira/browse/IGNITE-24633";)
     public void testVacuum() throws InterruptedException {
         // We should test the TTL-triggered vacuum.
         setTxResourceTtl(1);
@@ -211,7 +209,9 @@ public class ItTxResourcesVacuumTest extends 
ClusterPerTestIntegrationTest {
         // Check that the volatile PENDING state of the transaction is 
preserved.
         parallelTx1.commit();
         waitForTxStateVacuum(nodes, parallelTx1Id, partIdForParallelTx, true, 
10_000);
-        assertTrue(checkVolatileTxStateOnNodes(nodes, txId));
+        // Wait for condition is used instead of simple check because 
spreading information about transaction with txId=txId over all nodes
+        // takes time. There's no hb between (parallelTx1.commit() and/or 
parallelTx1 vacuumization) and txId state update.
+        assertTrue(waitForCondition(() -> checkVolatileTxStateOnNodes(nodes, 
txId), 10_000));
 
         Transaction parallelTx2 = node.transactions().begin();
         UUID parallelTx2Id = txId(parallelTx2);