Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160942938
--- 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 --
Was this code moved from somewhere (refactor), is it a bug fix or a new
feature related to the local restore?
---
