Greg Hogan created FLINK-5945:
---------------------------------
Summary: Close function in OuterJoinOperatorBase#executeOnCollections
Key: FLINK-5945
URL:
https://issues.apache.org/jira/browse/FLINK-5945 Project: Flink
Issue Type: Bug
Components: Core
Affects Versions: 1.1.4, 1.2.0, 1.3.0
Reporter: Greg Hogan
Assignee: Greg Hogan
Fix For: 1.3.0, 1.2.1, 1.1.4
{{OuterJoinOperatorBase#executeOnCollections}} does not call {{FunctionUtils.closeFunction(function);}}. I am seeing this affect the Gelly test for the {{HITS}} algorithm when using a convergence threshold rather than a fixed number of iterations.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)