This is an automated email from the ASF dual-hosted git repository.
tkalkirill 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 57a0bbafac IGNITE-23520 Fix flaky
IndexAvailabilityControllerTest#testMetastoreKeysAfterDropIndexWithTwoRemainingPartitions
(#4618)
57a0bbafac is described below
commit 57a0bbaface9a6f7b5534e8ba79501450472e234
Author: Kirill Tkalenko <[email protected]>
AuthorDate: Wed Oct 23 14:34:49 2024 +0300
IGNITE-23520 Fix flaky
IndexAvailabilityControllerTest#testMetastoreKeysAfterDropIndexWithTwoRemainingPartitions
(#4618)
---
.../index/IndexAvailabilityControllerTest.java | 22 +++++++++++-----------
1 file changed, 11 insertions(+), 11 deletions(-)
diff --git
a/modules/index/src/test/java/org/apache/ignite/internal/index/IndexAvailabilityControllerTest.java
b/modules/index/src/test/java/org/apache/ignite/internal/index/IndexAvailabilityControllerTest.java
index 96678fc7b7..c1ddbc2fd3 100644
---
a/modules/index/src/test/java/org/apache/ignite/internal/index/IndexAvailabilityControllerTest.java
+++
b/modules/index/src/test/java/org/apache/ignite/internal/index/IndexAvailabilityControllerTest.java
@@ -384,17 +384,7 @@ public class IndexAvailabilityControllerTest extends
BaseIgniteAbstractTest {
.thenReturn(new RowId(partitionId))
.thenReturn(null);
- indexBuilder.scheduleBuildIndex(
- tableId(TABLE_NAME),
- partitionId,
- indexId,
- indexStorage,
- mock(MvPartitionStorage.class),
- mock(ClusterNode.class),
- ANY_ENLISTMENT_CONSISTENCY_TOKEN
- );
-
- CompletableFuture<Void> finishBuildIndexFuture = new
CompletableFuture<>();
+ var finishBuildIndexFuture = new CompletableFuture<Void>();
indexBuilder.listen(new IndexBuildCompletionListener() {
@Override
@@ -405,6 +395,16 @@ public class IndexAvailabilityControllerTest extends
BaseIgniteAbstractTest {
}
});
+ indexBuilder.scheduleBuildIndex(
+ tableId(TABLE_NAME),
+ partitionId,
+ indexId,
+ indexStorage,
+ mock(MvPartitionStorage.class),
+ mock(ClusterNode.class),
+ ANY_ENLISTMENT_CONSISTENCY_TOKEN
+ );
+
assertThat(finishBuildIndexFuture, willCompleteSuccessfully());
}