Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r159880011
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamFactory.java
---
@@ -43,9 +44,9 @@ CheckpointStateOutputStream
createCheckpointStateOutputStream(
* Closes the stream factory, releasing all internal resources, but
does not delete any
* persistent checkpoint data.
*
- * @throws Exception Exceptions can be forwarded and will be logged by
the system
+ * @throws IOException Exceptions can be forwarded and will be logged
by the system
*/
- void close() throws Exception;
+ void close() throws IOException;
--- End diff --
What's this change for? Is it used anywhere? It seems to me like `close()`
is just a dead code and this method could be dropped, or did I missed something?
---
