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

amashenkov pushed a commit to branch ignite-21708
in repository https://gitbox.apache.org/repos/asf/ignite-3.git

commit add1e7edb578384bff0dc1400796923657c32626
Author: amashenkov <[email protected]>
AuthorDate: Wed Mar 20 17:03:27 2024 +0300

    Fix flaky test.
---
 .../org/apache/ignite/internal/catalog/CatalogManagerSelfTest.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogManagerSelfTest.java
 
b/modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogManagerSelfTest.java
index 9bf8f81b16..8294a47143 100644
--- 
a/modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogManagerSelfTest.java
+++ 
b/modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogManagerSelfTest.java
@@ -2229,7 +2229,10 @@ public class CatalogManagerSelfTest extends 
BaseCatalogManagerTest {
         var fireEventFuture = new CompletableFuture<Void>();
 
         manager.listen(CatalogEvent.INDEX_AVAILABLE, 
fromConsumer(fireEventFuture, (MakeIndexAvailableEventParameters parameters) -> 
{
-            assertEquals(indexId(pkIndexName(tableName)), 
parameters.indexId());
+            CatalogIndexDescriptor catalogIndexDescriptor = 
manager.index(parameters.indexId(), parameters.catalogVersion());
+
+            assertNotNull(catalogIndexDescriptor);
+            assertEquals(pkIndexName(tableName), 
catalogIndexDescriptor.name());
         }));
 
         createSomeTable(tableName);

Reply via email to