This is an automated email from the ASF dual-hosted git repository.
apolovtsev 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 00eef495f5 IGNITE-21728 Wait for the cursors to close in
ExecutionServiceImplTest (#3392)
00eef495f5 is described below
commit 00eef495f5185bcbb5e81e11d7488fffae2821d6
Author: Alexander Polovtcev <[email protected]>
AuthorDate: Mon Mar 11 14:28:57 2024 +0200
IGNITE-21728 Wait for the cursors to close in ExecutionServiceImplTest
(#3392)
---
.../internal/sql/engine/exec/ExecutionServiceImplTest.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git
a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
index 6cd336f9c3..96a2450d12 100644
---
a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
+++
b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
@@ -17,6 +17,7 @@
package org.apache.ignite.internal.sql.engine.exec;
+import static java.util.concurrent.CompletableFuture.allOf;
import static java.util.concurrent.CompletableFuture.completedFuture;
import static
org.apache.ignite.internal.catalog.CatalogService.DEFAULT_SCHEMA_NAME;
import static org.apache.ignite.internal.lang.IgniteStringFormatter.format;
@@ -24,6 +25,7 @@ import static
org.apache.ignite.internal.sql.engine.util.Commons.FRAMEWORK_CONFI
import static org.apache.ignite.internal.testframework.IgniteTestUtils.await;
import static
org.apache.ignite.internal.testframework.IgniteTestUtils.waitForCondition;
import static
org.apache.ignite.internal.testframework.matchers.CompletableFutureExceptionMatcher.willThrow;
+import static
org.apache.ignite.internal.testframework.matchers.CompletableFutureMatcher.willCompleteSuccessfully;
import static
org.apache.ignite.internal.testframework.matchers.CompletableFutureMatcher.willSucceedIn;
import static
org.apache.ignite.internal.util.CompletableFutures.nullCompletedFuture;
import static org.apache.ignite.lang.ErrorGroups.Common.NODE_LEFT_ERR;
@@ -679,7 +681,11 @@ public class ExecutionServiceImplTest extends
BaseIgniteAbstractTest {
assertEquals(queries.size(), resultCursors.size());
- resultCursors.forEach(AsyncCursor::closeAsync);
+ CompletableFuture<?>[] closeFutures = resultCursors.stream()
+ .map(AsyncCursor::closeAsync)
+ .toArray(CompletableFuture[]::new);
+
+ assertThat(allOf(closeFutures), willCompleteSuccessfully());
}
/**
@@ -712,7 +718,7 @@ public class ExecutionServiceImplTest extends
BaseIgniteAbstractTest {
assertThat(prefetchFut, willThrow(equalTo(expectedException)));
- cursor.closeAsync();
+ assertThat(cursor.closeAsync(), willCompleteSuccessfully());
}
/**
