You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Alexey Kukushkin (Jira)" <ji...@apache.org> on 2022/06/30 08:03:00 UTC
[jira] [Created] (IGNITE-17276) CompletableFuture#supplyAsync never completes with Ignite ExecutorService
Alexey Kukushkin created IGNITE-17276:
-----------------------------------------
Summary: CompletableFuture#supplyAsync never completes with Ignite ExecutorService
Key: IGNITE-17276
URL: https://issues.apache.org/jira/browse/IGNITE-17276
Project: Ignite
Issue Type: Bug
Components: compute
Affects Versions: 2.13
Reporter: Alexey Kukushkin
h3. Scenario: CompletableFuture#supplyAsync with Ignite ExecutorService
Given a cluster of two Ignite nodes
And Ignite {{ExecutorService}} for a remote node
When a task is executed using CompletableFuture#supplyAsync with the Ignite's {{ExecutorService}}
Then the task eventually completes
Actual result: the task never completes. Waiting on the task's future blocks forever.
Note; the scenario works fine if the task is executed on the local Ignite node.
{code:java}
public class Reproducer {
@Test
public void supplyIgniteExecutorToCompletableFuture() throws InterruptedException, ExecutionException {
Function<String, IgniteConfiguration> igniteCfgFactory = igniteName -> new IgniteConfiguration()
.setIgniteInstanceName(igniteName)
.setDiscoverySpi(
new TcpDiscoverySpi()
.setIpFinder(new TcpDiscoveryVmIpFinder().setAddresses(Collections.singleton("127.0.0.1:47500")))
);
try (var ignored = Ignition.start(igniteCfgFactory.apply("server"));
final var ignite = Ignition.start(igniteCfgFactory.apply("app"))) {
final var igniteExecutor = ignite.executorService(ignite.cluster().forRemotes());
final var future = CompletableFuture.supplyAsync(new Task(), igniteExecutor);
final var result = future.get();
assertNotNull(result);
}
}
private static class Task implements Supplier<String> {
@Override public String get() {
return UUID.randomUUID().toString();
}
}
}
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)