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 b0adb1acc87 IGNITE-26343 Fixed flaky
ItTxResourcesVacuumTest.testVacuumWithCleanupDelay (#6952)
b0adb1acc87 is described below
commit b0adb1acc87e5bde17688c1c0a504e11702a7156
Author: Denis Chudov <[email protected]>
AuthorDate: Thu Nov 13 14:08:12 2025 +0400
IGNITE-26343 Fixed flaky ItTxResourcesVacuumTest.testVacuumWithCleanupDelay
(#6952)
---
.../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 625016cf1f0..304aeae44ee 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
@@ -365,7 +365,7 @@ public class ItTxResourcesVacuumTest extends
ClusterPerTestIntegrationTest {
*
* <ul>
* <li>Start a transaction;</li>
- * <li>Generate some tuple and define on which nodes it would be
hosted;</li>
+ * <li>Take some tuple and define on which nodes it would be
hosted;</li>
* <li>Choose one more node that doesn't host the first tuple and
choose a tuple that will be sent on this node as primary;</li>
* <li>Upsert both tuples within a transaction;</li>
* <li>Block {@link TxCleanupMessage}-s from commit partition
primary;</li>
@@ -388,8 +388,8 @@ public class ItTxResourcesVacuumTest extends
ClusterPerTestIntegrationTest {
log.info("Test: Loading the data [tx={}].", txId);
- // Generate some tuple and define on which nodes it would be hosted.
- Tuple tuple0 = findTupleToBeHostedOnNode(node, TABLE_NAME, tx,
INITIAL_TUPLE, NEXT_TUPLE, true);
+ // Take some tuple and define on which nodes it would be hosted.
+ Tuple tuple0 = INITIAL_TUPLE;
int commitPartId = partitionIdForTuple(node, TABLE_NAME, tuple0, tx);