Github user StephanEwen commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5239#discussion_r160492829
  
    --- 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 --
    
    I think this method is actually removed in the latest master.


---

Reply via email to