From 4541cca52454ae9b67e33c564c455a9e4e0579e6 Mon Sep 17 00:00:00 2001 From: zstan Date: Mon, 19 Oct 2026 16:37:42 +0300 Subject: [PATCH] IGNITE-29166 Fix flaky TableDdlIntegrationTest#alterTableLogging --- .../query/calcite/integration/TableDdlIntegrationTest.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/TableDdlIntegrationTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/TableDdlIntegrationTest.java index 101b61945aadc..b691b49505a13 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/TableDdlIntegrationTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/TableDdlIntegrationTest.java @@ -40,6 +40,7 @@ import org.apache.ignite.configuration.BinaryConfiguration; import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgniteInterruptedCheckedException; import org.apache.ignite.internal.MarshallerContextImpl; import org.apache.ignite.internal.binary.BinaryContext; import org.apache.ignite.internal.processors.cache.IgniteInternalCache; @@ -1212,7 +1213,7 @@ public void alterTableChangeColumnAndUseIndex() { * Alter table logging/nologing. */ @Test - public void alterTableLogging() { + public void alterTableLogging() throws IgniteInterruptedCheckedException { String cacheName = "cache"; client.getOrCreateCache(new CacheConfiguration<>(cacheName) @@ -1222,11 +1223,11 @@ public void alterTableLogging() { sql("alter table \"" + cacheName + "\".Integer nologging"); - assertFalse(client.cluster().isWalEnabled(cacheName)); + assertTrue(GridTestUtils.waitForCondition(() -> !client.cluster().isWalEnabled(cacheName), 1_000)); sql("alter table \"" + cacheName + "\".Integer logging"); - assertTrue(client.cluster().isWalEnabled(cacheName)); + assertTrue(GridTestUtils.waitForCondition(() -> client.cluster().isWalEnabled(cacheName), 1_000)); } /**