[IGNITE-21818] Broadcasting job that returns null fails

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 3.0.0-beta2
• Component/s: compute
• Labels: ignite-3
• Assignee: Roman Puchkovskiy
• Reporter: Vadim Pakhnushev
• Reviewer: Vadim Pakhnushev
• Created: 20/Mar/24 11:31
• Updated: 29/Mar/24 12:27
• Resolved: 29/Mar/24 12:27

Description

Running the job which returns null as a result via IgniteCompute.executeBroadcastAsync or executeBroadcast fails with the NPE:

 

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)
 

 

 

Issue Links

• Blocked: IGNITE-21876 Prevent thread hijacking via IgniteCompute
• links to: GitHub Pull Request #3520