Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5723#discussion_r175705138 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java --- @@ -279,15 +279,14 @@ protected OperatorStateBackend operatorStateBackend( if (restoreStateAlternatives.hasNext()) { - final CloseableRegistry closeableRegistry = new CloseableRegistry(); - Collection<OperatorStateHandle> rawOperatorState = restoreStateAlternatives.next(); // TODO currently this does not support local state recovery, so we expect there is only one handle. Preconditions.checkState( !restoreStateAlternatives.hasNext(), "Local recovery is currently not implemented for raw operator state, but found state alternative."); if (rawOperatorState != null) { + final CloseableRegistry closeableRegistry = new CloseableRegistry(); --- End diff -- Can't we even move this registry into the anonymous class?
---