[jira] [Created] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

Posted by Shang Yuanchun (Jira) on Jun 18, 2021; 7:28am
URL: http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/jira-Created-FLINK-23030-PartitionRequestClientFactory-createPartitionRequestClient-should-throw-whee-tp51492.html

Jin Xing created FLINK-23030:
--------------------------------

             Summary: PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure
                 Key: FLINK-23030
                 URL: https://issues.apache.org/jira/browse/FLINK-23030
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Network
            Reporter: Jin Xing


In current _PartitionRequestClientFactory#createPartitionRequestClient_, _ChannelFuture#await()_ is invoked, thus to build a connection to remote synchronously.

But with the doc of _io.netty.util.concurrent.Future_ [1] and its implementation _io.netty.channel.DefaultChannelPromise_ [2], _ChannelFuture#await()_ never throws when completed with failure. I guess what Flink needs is _ChannelFuture#sync()._

 

[1][https://netty.io/4.1/api/io/netty/util/concurrent/class-use/Future.html]

[2] https://github.com/netty/netty/blob/4.1/transport/src/main/java/io/netty/channel/DefaultChannelPromise.java



--
This message was sent by Atlassian Jira
(v8.3.4#803005)