You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ib...@apache.org on 2021/08/13 15:06:15 UTC
[ignite-3] branch main updated: IGNITE-15305 Fixed flaky
ITDistributedConfigurationStorageTest#testRestartWithPds. (#276)
This is an automated email from the ASF dual-hosted git repository.
ibessonov 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 3e18a6c IGNITE-15305 Fixed flaky ITDistributedConfigurationStorageTest#testRestartWithPds. (#276)
3e18a6c is described below
commit 3e18a6c6b2e74826ea159f3ce945fa8ee2940cb8
Author: ibessonov <be...@gmail.com>
AuthorDate: Fri Aug 13 18:06:09 2021 +0300
IGNITE-15305 Fixed flaky ITDistributedConfigurationStorageTest#testRestartWithPds. (#276)
Signed-off-by: ibessonov <be...@gmail.com>
---
.../internal/storage/ITDistributedConfigurationStorageTest.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/storage/ITDistributedConfigurationStorageTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/storage/ITDistributedConfigurationStorageTest.java
index 002f73a..88df9de 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/storage/ITDistributedConfigurationStorageTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/storage/ITDistributedConfigurationStorageTest.java
@@ -21,6 +21,7 @@ import java.io.Serializable;
import java.nio.file.Path;
import java.util.List;
import java.util.Map;
+import java.util.Objects;
import java.util.stream.Stream;
import org.apache.ignite.configuration.RootKey;
import org.apache.ignite.configuration.annotation.ConfigurationType;
@@ -45,6 +46,8 @@ import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import static java.util.concurrent.CompletableFuture.completedFuture;
+import static org.apache.ignite.internal.metastorage.MetaStorageManager.APPLIED_REV;
+import static org.apache.ignite.internal.testframework.IgniteTestUtils.waitForCondition;
import static org.apache.ignite.internal.testframework.matchers.CompletableFutureMatcher.willBe;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.equalTo;
@@ -171,6 +174,8 @@ public class ITDistributedConfigurationStorageTest {
node.start();
assertThat(node.cfgStorage.write(data, 0), willBe(equalTo(true)));
+
+ waitForCondition(() -> Objects.nonNull(node.vaultManager.get(APPLIED_REV).join().value()), 3000);
}
finally {
node.stop();