[flink] 01/03: [hotfix] Remove useless exception in SubtaskCheckpointCoordinatorImpl

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit e6981bb476188fb5893a35256d00bda4b38947c8
Author: 1996fanrui <1996fan...@gmail.com>
AuthorDate: Thu Oct 13 15:25:33 2022 +0800

    [hotfix] Remove useless exception in SubtaskCheckpointCoordinatorImpl
---
 .../streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java   | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
index fe36c31efc6..82b6e7f8093 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
@@ -137,8 +137,7 @@ class SubtaskCheckpointCoordinatorImpl implements 
SubtaskCheckpointCoordinator {
                             ChannelStateWriter, Long, CompletableFuture<Void>, 
CheckpointException>
                     prepareInputSnapshot,
             int maxRecordAbortedCheckpoints,
-            DelayableTimer registerTimer)
-            throws IOException {
+            DelayableTimer registerTimer) {
         this(
                 checkpointStorage,
                 taskName,
@@ -169,8 +168,7 @@ class SubtaskCheckpointCoordinatorImpl implements 
SubtaskCheckpointCoordinator {
             int maxRecordAbortedCheckpoints,
             ChannelStateWriter channelStateWriter,
             boolean enableCheckpointAfterTasksFinished,
-            DelayableTimer registerTimer)
-            throws IOException {
+            DelayableTimer registerTimer) {
         this.checkpointStorage =
                 new 
CachingCheckpointStorageWorkerView(checkNotNull(checkpointStorage));
         this.taskName = checkNotNull(taskName);