flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fabian Hueske (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds
Date Thu, 30 Apr 2015 15:32:06 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14521656#comment-14521656

Fabian Hueske commented on FLINK-1951:

It turned out that the channel to the solution set update task was meant to be blocking, i.e.,
it should first collect all updates and apply them after the join with the solution set was
done. That way the solution set is not concurrently probed and updated.

The optimizer did the right decisions, however the decisions were not correctly translated
into the JobGraph. 

> NullPointerException in DeltaIteration when no ForwardedFileds
> --------------------------------------------------------------
>                 Key: FLINK-1951
>                 URL: https://issues.apache.org/jira/browse/FLINK-1951
>             Project: Flink
>          Issue Type: Bug
>          Components: Iterations
>    Affects Versions: 0.9
>            Reporter: Vasia Kalavri
>            Assignee: Fabian Hueske
>            Priority: Critical
> The following exception is thrown by the Connected Components example, if the @ForwardedFieldsFirst("*")
annotation from the ComponentIdFilter join is removed:
> Caused by: java.lang.NullPointerException
> 	at org.apache.flink.examples.java.graph.ConnectedComponents$ComponentIdFilter.join(ConnectedComponents.java:186)
> 	at org.apache.flink.examples.java.graph.ConnectedComponents$ComponentIdFilter.join(ConnectedComponents.java:1)
> 	at org.apache.flink.runtime.operators.JoinWithSolutionSetSecondDriver.run(JoinWithSolutionSetSecondDriver.java:198)
> 	at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
> 	at org.apache.flink.runtime.iterative.task.AbstractIterativePactTask.run(AbstractIterativePactTask.java:139)
> 	at org.apache.flink.runtime.iterative.task.IterationIntermediatePactTask.run(IterationIntermediatePactTask.java:92)
> 	at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
> 	at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:217)
> 	at java.lang.Thread.run(Thread.java:745)
> [Code | https://github.com/vasia/flink/tree/cc-test] and [dataset | http://snap.stanford.edu/data/com-DBLP.html]
to reproduce.

This message was sent by Atlassian JIRA

View raw message