[hotfix][runtime] Drop unused throws IOException

Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/635c29d8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/635c29d8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/635c29d8

Branch: refs/heads/master
Commit: 635c29d87cc036e96a458b1ba76d51f6135668e4
Parents: 5722814
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
Authored: Thu Jan 25 16:23:36 2018 +0100
Committer: Piotr Nowojski <piotr.nowoj...@gmail.com>
Committed: Mon Feb 19 12:21:32 2018 +0100

----------------------------------------------------------------------
 .../runtime/io/network/partition/PipelinedSubpartition.java      | 4 ++--
 .../runtime/io/network/partition/PipelinedSubpartitionView.java  | 4 ++--
 .../runtime/io/network/partition/ResultSubpartitionView.java     | 2 +-
 .../runtime/io/network/partition/SpillableSubpartitionView.java  | 2 +-
 .../runtime/io/network/partition/SpilledSubpartitionView.java    | 2 +-
 .../runtime/io/network/netty/CancelPartitionRequestTest.java     | 2 +-
 6 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/635c29d8/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
index e1c53c0..2fa512a 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
@@ -58,7 +58,7 @@ class PipelinedSubpartition extends ResultSubpartition {
        }
 
        @Override
-       public boolean add(BufferConsumer bufferConsumer) throws IOException {
+       public boolean add(BufferConsumer bufferConsumer) {
                return add(bufferConsumer, false);
        }
 
@@ -68,7 +68,7 @@ class PipelinedSubpartition extends ResultSubpartition {
                LOG.debug("Finished {}.", this);
        }
 
-       private boolean add(BufferConsumer bufferConsumer, boolean finish) 
throws IOException {
+       private boolean add(BufferConsumer bufferConsumer, boolean finish) {
                checkNotNull(bufferConsumer);
 
                synchronized (buffers) {

http://git-wip-us.apache.org/repos/asf/flink/blob/635c29d8/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
index 6fd6022..21abd04 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
@@ -21,7 +21,7 @@ package org.apache.flink.runtime.io.network.partition;
 import 
org.apache.flink.runtime.io.network.partition.ResultSubpartition.BufferAndBacklog;
 
 import javax.annotation.Nullable;
-import java.io.IOException;
+
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import static org.apache.flink.util.Preconditions.checkNotNull;
@@ -52,7 +52,7 @@ class PipelinedSubpartitionView implements 
ResultSubpartitionView {
        }
 
        @Override
-       public void notifyBuffersAvailable(long numBuffers) throws IOException {
+       public void notifyBuffersAvailable(long numBuffers) {
                availabilityListener.notifyBuffersAvailable(numBuffers);
        }
 

http://git-wip-us.apache.org/repos/asf/flink/blob/635c29d8/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
index bb7e50c..9b0344e 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
@@ -43,7 +43,7 @@ public interface ResultSubpartitionView {
        @Nullable
        BufferAndBacklog getNextBuffer() throws IOException, 
InterruptedException;
 
-       void notifyBuffersAvailable(long buffers) throws IOException;
+       void notifyBuffersAvailable(long buffers);
 
        void releaseAllResources() throws IOException;
 

http://git-wip-us.apache.org/repos/asf/flink/blob/635c29d8/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
index 8a20e65..6c173a3 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
@@ -182,7 +182,7 @@ class SpillableSubpartitionView implements 
ResultSubpartitionView {
        }
 
        @Override
-       public void notifyBuffersAvailable(long buffers) throws IOException {
+       public void notifyBuffersAvailable(long buffers) {
                // We do the availability listener notification one by one
        }
 

http://git-wip-us.apache.org/repos/asf/flink/blob/635c29d8/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
index 1c1468e..d1917e6 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
@@ -166,7 +166,7 @@ class SpilledSubpartitionView implements 
ResultSubpartitionView, NotificationLis
        }
 
        @Override
-       public void notifyBuffersAvailable(long buffers) throws IOException {
+       public void notifyBuffersAvailable(long buffers) {
                // We do the availability listener notification either directly 
on
                // construction of this view (when everything has been spilled) 
or
                // as soon as spilling is done and we are notified about it in 
the

http://git-wip-us.apache.org/repos/asf/flink/blob/635c29d8/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
index 09d8634..4c4939b 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
@@ -198,7 +198,7 @@ public class CancelPartitionRequestTest {
                }
 
                @Override
-               public void notifyBuffersAvailable(long buffers) throws 
IOException {
+               public void notifyBuffersAvailable(long buffers) {
                }
 
                @Override

Reply via email to