Ted Yu created FLINK-2868: ----------------------------- Summary: Missing null check for operatorChain in StreamTask#invoke() Key: FLINK-2868 URL: https://issues.apache.org/jira/browse/FLINK-2868 Project: Flink Issue Type: Bug Reporter: Ted Yu
{code} // release the output resources. this method should never fail. if (operatorChain != null) { operatorChain.releaseOutputs(); } ... if (!disposed) { disposeAllOperators(); } {code} If operatorChain is null, disposeAllOperators() shouldn't be called where operatorChain.getAllOperators() is called. -- This message was sent by Atlassian JIRA (v6.3.4#6332)