[ignite-3] branch ignite-16771 updated: testClientSendsComputeJobToTargetNodeWhenDirectConnectionExists done

[ptupitsyn]

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

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


The following commit(s) were added to refs/heads/ignite-16771 by this push:
     new 7e72cd294 
testClientSendsComputeJobToTargetNodeWhenDirectConnectionExists done
7e72cd294 is described below

commit 7e72cd294d8f50f0d136664dffca6d635ae3babf
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Thu Apr 14 18:54:34 2022 +0300

    testClientSendsComputeJobToTargetNodeWhenDirectConnectionExists done
---
 .../src/test/java/org/apache/ignite/client/ClientComputeTest.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java 
b/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java
index b4c72f8ef..4234205f1 100644
--- 
a/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java
+++ 
b/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java
@@ -24,6 +24,7 @@ import java.util.Set;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 import org.apache.ignite.client.fakes.FakeIgnite;
+import org.apache.ignite.internal.testframework.IgniteTestUtils;
 import org.apache.ignite.internal.util.IgniteUtils;
 import org.apache.ignite.network.ClusterNode;
 import org.apache.ignite.network.NetworkAddress;
@@ -48,7 +49,7 @@ public class ClientComputeTest {
         initServers(reqId -> false);
 
         try (var client = getClient()) {
-            Thread.sleep(500);
+            IgniteTestUtils.waitForCondition(() -> client.connections().size() 
== 3, 3000);
 
             String res1 = 
client.compute().<String>execute(getClusterNodes("s1"), "job").join();
             String res2 = 
client.compute().<String>execute(getClusterNodes("s2"), "job").join();