You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by pp...@apache.org on 2026/04/17 14:10:51 UTC
(ignite-3) branch main updated: IGNITE-28571 Fix compilation of PersistentTxStateVacuumizerTest under java 11 (#8001)
This is an automated email from the ASF dual-hosted git repository.
ppa 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 de1cc0bf48f IGNITE-28571 Fix compilation of PersistentTxStateVacuumizerTest under java 11 (#8001)
de1cc0bf48f is described below
commit de1cc0bf48f300cd15c74525827715bd9feae357
Author: Pavel Pereslegin <xx...@gmail.com>
AuthorDate: Fri Apr 17 17:10:45 2026 +0300
IGNITE-28571 Fix compilation of PersistentTxStateVacuumizerTest under java 11 (#8001)
---
.../ignite/internal/tx/impl/PersistentTxStateVacuumizerTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/modules/transactions/src/test/java/org/apache/ignite/internal/tx/impl/PersistentTxStateVacuumizerTest.java b/modules/transactions/src/test/java/org/apache/ignite/internal/tx/impl/PersistentTxStateVacuumizerTest.java
index a6386c227aa..32338f27395 100644
--- a/modules/transactions/src/test/java/org/apache/ignite/internal/tx/impl/PersistentTxStateVacuumizerTest.java
+++ b/modules/transactions/src/test/java/org/apache/ignite/internal/tx/impl/PersistentTxStateVacuumizerTest.java
@@ -33,6 +33,7 @@ import java.util.Map;
import java.util.Set;
import java.util.UUID;
import java.util.concurrent.CompletableFuture;
+import java.util.stream.Collectors;
import org.apache.ignite.internal.hlc.HybridClockImpl;
import org.apache.ignite.internal.hlc.TestClockService;
import org.apache.ignite.internal.network.InternalClusterNode;
@@ -117,7 +118,7 @@ class PersistentTxStateVacuumizerTest extends BaseIgniteAbstractTest {
// Each request should have at most VACUUM_BATCH_SIZE tx IDs.
assertThat(
- requestCaptor.getAllValues().stream().map(r -> r.transactionIds().size()).toList(),
+ requestCaptor.getAllValues().stream().map(r -> r.transactionIds().size()).collect(Collectors.toUnmodifiableList()),
everyItem(lessThanOrEqualTo(VACUUM_BATCH_SIZE))
);