Hello
I have set RoundRobinLoadBalancingSpi.
I have a RestFul calls
IgniteCompute compute = ignite.compute().withTimeout(25*1000).withAsync();
compute.call(new RestClusterTask(.....)
"RestClusterTask implements IgniteCallable"
Inside RestClusterTask calls a second Service(LWMServerService implments
Service) into a cluster.
My Restful "response" works in this way:
ComputeTaskFuture<List<TuplePayload<ErrorPayload, LWMResponsePayload>>> fut
= compute.future();
fut.get(10,
TimeUnit.SECONDS).parallelStream().forEach(tuplePayload -> {
payloads.add(LaraPayload.tuple(tuplePayload));
});
When RestClusterTask and LWMServerService runs on the same machine
10.1.1.231 all works fine
2017-02-17 21:35:58,747 | INFO | TEST-ENVIROMENT% | RestClusterTask
| 216 - org.flexvalley.ecosystem.management - 1.0.2.SNAPSHOT |
iClusterService load on node TcpDiscoveryNode
[id=3937dfe6-fdaa-4345-a760-5e85d472a613, addrs=[0:0:0:0:0:0:0:1%lo,
10.1.1.231, 10.1.1.240, 127.0.0.1], sockAddrs=[/10.1.1.231:47500,
/0:0:0:0:0:0:0:1%lo:47500, /10.1.1.240:47500, /127.0.0.1:47500],
discPort=47500, order=8, intOrder=5, lastExchangeTime=1487363758640,
loc=true, ver=1.8.0#19700101-sha1:00000000, isClient=false]
2017-02-17 21:35:58,754 | INFO | TEST-ENVIROMENT% | LWMServerService
| 183 - org.flexvalley.ecosystem.lwmserver - 1.0.2.SNAPSHOT |
iClusterService load on node TcpDiscoveryNode
[id=3937dfe6-fdaa-4345-a760-5e85d472a613, addrs=[0:0:0:0:0:0:0:1%lo,
10.1.1.231, 10.1.1.240, 127.0.0.1], sockAddrs=[/10.1.1.231:47500,
/0:0:0:0:0:0:0:1%lo:47500, /10.1.1.240:47500, /127.0.0.1:47500],
discPort=47500, order=8, intOrder=5, lastExchangeTime=1487363758640,
loc=true, ver=1.8.0#19700101-sha1:00000000, isClient=false]
But when
2017-02-17 21:42:59,731 | INFO | TEST-ENVIROMENT% | RestClusterTask
| 216 - org.flexvalley.ecosystem.management - 1.0.2.SNAPSHOT |
iClusterService load on node TcpDiscoveryNode
[id=cf414160-d055-45ae-9bb8-c760b9e437aa, addrs=[0:0:0:0:0:0:0:1%lo,
10.1.1.230, 10.1.1.240, 127.0.0.1], sockAddrs=[/10.1.1.230:47500,
/0:0:0:0:0:0:0:1%lo:47500, /10.1.1.240:47500, /127.0.0.1:47500],
discPort=47500, order=10, intOrder=6, lastExchangeTime=1487364179049,
loc=true, ver=1.8.0#19700101-sha1:00000000, isClient=false]
2017-02-17 21:42:59,741 | INFO | TEST-ENVIROMENT% | LWMServerService
| 183 - org.flexvalley.ecosystem.lwmserver - 1.0.2.SNAPSHOT |
iClusterService load on node TcpDiscoveryNode
[id=3937dfe6-fdaa-4345-a760-5e85d472a613, addrs=[0:0:0:0:0:0:0:1%lo,
10.1.1.231, 10.1.1.240, 127.0.0.1], sockAddrs=[/10.1.1.231:47500,
/0:0:0:0:0:0:0:1%lo:47500, /10.1.1.240:47500, /127.0.0.1:47500],
discPort=47500, order=8, intOrder=5, lastExchangeTime=1487364179049,
loc=true, ver=1.8.0#19700101-sha1:00000000, isClient=false]
I receive Timeout was reached before computation completed.
I hope that you can give me some helps please...
Regards
Devis
