Vadim Pakhnushev created IGNITE-21818:
-----------------------------------------
Summary: Broadcasting job that returns null fails
Key: IGNITE-21818
URL: https://issues.apache.org/jira/browse/IGNITE-21818
Project: Ignite
Issue Type: Bug
Components: compute
Reporter: Vadim Pakhnushev
Assignee: Vadim Pakhnushev
Running the job which returns null as a result via
IgniteCompute.executeBroadcastAsync or executeBroadcast fails with the NPE:
{code:java}
Caused by: java.lang.NullPointerException
at java.base/java.util.Objects.requireNonNull(Objects.java:221)
at
java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:178)
at
java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
at
java.base/java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764)
at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
at
java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578)
at
org.apache.ignite.compute.IgniteCompute.lambda$executeBroadcastAsync$3(IgniteCompute.java:508)
at
java.base/java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:680)
at
java.base/java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:658)
at
java.base/java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2094)
at
org.apache.ignite.compute.IgniteCompute.executeBroadcastAsync(IgniteCompute.java:507)
at
org.apache.ignite.compute.IgniteCompute.executeBroadcastAsync(IgniteCompute.java:529)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
