You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Roman Puchkovskiy (Jira)" <ji...@apache.org> on 2024/03/29 11:16:00 UTC
[jira] [Updated] (IGNITE-21818) Broadcasting job that returns null fails
[ https://issues.apache.org/jira/browse/IGNITE-21818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Roman Puchkovskiy updated IGNITE-21818:
---------------------------------------
Priority: Blocker (was: Major)
> 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: Roman Puchkovskiy
> Priority: Blocker
> Labels: ignite-3
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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)