Stephan Ewen created FLINK-1074:
-----------------------------------
Summary: 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)
Locked
