Ted Yu created FLINK-2708:
-----------------------------
Summary: Potential null pointer dereference in
JoinWithSolutionSetFirstDriver#run()
Key: FLINK-2708
URL: https://issues.apache.org/jira/browse/FLINK-2708
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
{code}
while (this.running && ((probeSideRecord =
probeSideInput.next(probeSideRecord)) != null)) {
IT1 matchedRecord =
prober.getMatchFor(probeSideRecord, buildSideRecord);
joinFunction.join(matchedRecord,
probeSideRecord, collector);
}
{code}
The return value from getMatchFor() should be checked to avoid NPE.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
