[
https://issues.apache.org/jira/browse/FLINK-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1074.
----------------------------------
Resolution: Fixed
Fixed with 00840599a7a498cbd19d524ab5ad698365cbab4f
> Project Join fails when input tuple is null
> -------------------------------------------
>
> Key: FLINK-1074
> URL: https://issues.apache.org/jira/browse/FLINK-1074
> Project: Flink
> Issue Type: Bug
> Components: Java API
> Affects Versions: 0.6-incubating, 0.7-incubating
> Reporter: Stephan Ewen
> Assignee: Fabian Hueske
> Fix For: 0.7-incubating, 0.6.1-incubating
>
>
> When joining with the solution set (later: in outer joins), one of the input
> tuple s of the join function may be null. The ProjectJoin fails in that case
> with a NullPointerException.
> {noformat}
> Exception in thread "main"
> org.apache.flink.runtime.client.JobExecutionException:
> java.lang.NullPointerException
> at
> org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction.join(JoinOperator.java:935)
> at
> org.apache.flink.runtime.operators.JoinWithSolutionSetSecondDriver.run(JoinWithSolutionSetSecondDriver.java:143)
> at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:510)
> at
> org.apache.flink.runtime.iterative.task.AbstractIterativePactTask.run(AbstractIterativePactTask.java:137)
> at
> org.apache.flink.runtime.iterative.task.IterationIntermediatePactTask.run(IterationIntermediatePactTask.java:92)
> at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:375)
> at
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:265)
> at java.lang.Thread.run(Thread.java:744)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
