You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by pt...@apache.org on 2022/08/22 12:15:28 UTC
[ignite-3] branch main updated: IGNITE-17491 Fix testIgniteExceptionInJobPropagatesToClientWithMessageAndCodeAndTraceId flakiness (#1030)
This is an automated email from the ASF dual-hosted git repository.
ptupitsyn 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 812572a6cf IGNITE-17491 Fix testIgniteExceptionInJobPropagatesToClientWithMessageAndCodeAndTraceId flakiness (#1030)
812572a6cf is described below
commit 812572a6cf4b6a11541dd38a73aa1b73faf20277
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Mon Aug 22 15:15:24 2022 +0300
IGNITE-17491 Fix testIgniteExceptionInJobPropagatesToClientWithMessageAndCodeAndTraceId flakiness (#1030)
Wait for background client connections to be established.
---
.../ignite/internal/runner/app/client/ItAbstractThinClientTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItAbstractThinClientTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItAbstractThinClientTest.java
index 2e0a7543a2..2e6d9b6861 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItAbstractThinClientTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItAbstractThinClientTest.java
@@ -34,6 +34,7 @@ import org.apache.ignite.client.IgniteClient;
import org.apache.ignite.internal.app.IgniteImpl;
import org.apache.ignite.internal.schema.configuration.SchemaConfigurationConverter;
import org.apache.ignite.internal.testframework.IgniteAbstractTest;
+import org.apache.ignite.internal.testframework.IgniteTestUtils;
import org.apache.ignite.internal.testframework.WorkDirectory;
import org.apache.ignite.internal.testframework.WorkDirectoryExtension;
import org.apache.ignite.internal.util.IgniteUtils;
@@ -71,7 +72,7 @@ public abstract class ItAbstractThinClientTest extends IgniteAbstractTest {
* Before each.
*/
@BeforeAll
- void beforeAll(TestInfo testInfo, @WorkDirectory Path workDir) {
+ void beforeAll(TestInfo testInfo, @WorkDirectory Path workDir) throws InterruptedException {
this.workDir = workDir;
String node0Name = testNodeName(testInfo, 3344);
@@ -120,6 +121,7 @@ public abstract class ItAbstractThinClientTest extends IgniteAbstractTest {
);
client = IgniteClient.builder().addresses(getClientAddresses().toArray(new String[0])).build();
+ IgniteTestUtils.waitForCondition(() -> client.connections().size() == 2, 3000);
}
/**