[flink] 01/02: [FLINK-23621] Add InterruptedException to ProcessingTimeService#onProcessingTime

[arvid]

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

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

commit 134f388323f0c2b625504fc58e874133f467f781
Author: Fabian Paul <fabianp...@ververica.com>
AuthorDate: Fri Aug 13 11:44:59 2021 +0200

    [FLINK-23621] Add InterruptedException to 
ProcessingTimeService#onProcessingTime
---
 .../org/apache/flink/connector/file/sink/writer/FileWriterTest.java | 6 +++---
 .../src/main/java/org/apache/flink/api/connector/sink/Sink.java     | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileWriterTest.java
 
b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileWriterTest.java
index 0651031..2115f37 100644
--- 
a/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileWriterTest.java
+++ 
b/flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileWriterTest.java
@@ -192,7 +192,7 @@ public class FileWriterTest {
     }
 
     @Test
-    public void testOnProcessingTime() throws IOException {
+    public void testOnProcessingTime() throws IOException, 
InterruptedException {
         File outDir = TEMP_FOLDER.newFolder();
         Path path = new Path(outDir.toURI());
 
@@ -327,7 +327,7 @@ public class FileWriterTest {
             if (time <= now) {
                 try {
                     processingTimeCallback.onProcessingTime(now);
-                } catch (IOException e) {
+                } catch (IOException | InterruptedException e) {
                     ExceptionUtils.rethrow(e);
                 }
             } else {
@@ -335,7 +335,7 @@ public class FileWriterTest {
             }
         }
 
-        public void advanceTo(long time) throws IOException {
+        public void advanceTo(long time) throws IOException, 
InterruptedException {
             if (time > now) {
                 now = time;
 
diff --git 
a/flink-core/src/main/java/org/apache/flink/api/connector/sink/Sink.java 
b/flink-core/src/main/java/org/apache/flink/api/connector/sink/Sink.java
index 99d47e9..91c4383 100644
--- a/flink-core/src/main/java/org/apache/flink/api/connector/sink/Sink.java
+++ b/flink-core/src/main/java/org/apache/flink/api/connector/sink/Sink.java
@@ -193,7 +193,7 @@ public interface Sink<InputT, CommT, WriterStateT, 
GlobalCommT> extends Serializ
              *
              * @param time The time this callback was registered for.
              */
-            void onProcessingTime(long time) throws IOException;
+            void onProcessingTime(long time) throws IOException, 
InterruptedException;
         }
     }
 }