[flink] 01/03: [FLINK-28695][hotfix][network] Remove some unused exceptions

[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 4b10f422f20ca22661a1870eadc343cab4a44567
Author: 1996fanrui <1996fan...@gmail.com>
AuthorDate: Sun Nov 20 15:30:58 2022 +0800

    [FLINK-28695][hotfix][network] Remove some unused exceptions
---
 .../io/network/netty/CreditBasedPartitionRequestClientHandler.java    | 2 +-
 .../flink/runtime/io/network/netty/NettyPartitionRequestClient.java   | 4 ++--
 .../runtime/io/network/netty/PartitionRequestClientFactoryTest.java   | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java
index 6480b49fef7..5e8ab08c423 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java
@@ -275,7 +275,7 @@ class CreditBasedPartitionRequestClientHandler extends 
ChannelInboundHandlerAdap
         }
     }
 
-    private void decodeMsg(Object msg) throws Throwable {
+    private void decodeMsg(Object msg) {
         final Class<?> msgClazz = msg.getClass();
 
         // ---- Buffer --------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java
index de2fc747ecb..2bfa28b6040 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java
@@ -133,7 +133,7 @@ public class NettyPartitionRequestClient implements 
PartitionRequestClient {
         final ChannelFutureListener listener =
                 new ChannelFutureListener() {
                     @Override
-                    public void operationComplete(ChannelFuture future) throws 
Exception {
+                    public void operationComplete(ChannelFuture future) {
                         if (!future.isSuccess()) {
                             clientHandler.removeInputChannel(inputChannel);
                             inputChannel.onError(
@@ -196,7 +196,7 @@ public class NettyPartitionRequestClient implements 
PartitionRequestClient {
                 .addListener(
                         new ChannelFutureListener() {
                             @Override
-                            public void operationComplete(ChannelFuture 
future) throws Exception {
+                            public void operationComplete(ChannelFuture 
future) {
                                 if (!future.isSuccess()) {
                                     inputChannel.onError(
                                             new LocalTransportException(
diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
index c676046913d..f8ba8118a77 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
@@ -182,7 +182,7 @@ public class PartitionRequestClientFactoryTest extends 
TestLogger {
 
     // see https://issues.apache.org/jira/browse/FLINK-18821
     @TestTemplate
-    void testFailureReportedToSubsequentRequests() throws Exception {
+    void testFailureReportedToSubsequentRequests() {
         PartitionRequestClientFactory factory =
                 new PartitionRequestClientFactory(
                         new FailingNettyClient(), 2, 1, 
connectionReuseEnabled);