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)