You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/11/21 10:45:08 UTC
[flink] 01/03: [FLINK-28695][hotfix][network] Remove some unused exceptions
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 <19...@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);