Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r162584371
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -316,7 +292,38 @@ private void
initOperatorState(Collection<OperatorStateHandle> operatorStateHand
* @throws Exception An exception in this method causes the operator to
fail.
*/
@Override
- public void close() throws Exception {}
+ public void close() throws Exception {
--- End diff --
ð
---
