Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r162259728 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java --- @@ -82,10 +83,17 @@ protected void channelRead0(ChannelHandlerContext ctx, NettyMessage msg) throws LOG.debug("Read channel on {}: {}.", ctx.channel().localAddress(), request); try { - SequenceNumberingViewReader reader = new SequenceNumberingViewReader( - request.receiverId, - request.credit, - outboundQueue); + NetworkSequenceViewReader reader; + if (request.credit > 0) { + reader = new CreditBasedSequenceNumberingViewReader( + request.receiverId, + request.credit, + outboundQueue); + } else { + reader = new SequenceNumberingViewReader( + request.receiverId, + outboundQueue); + } --- End diff -- Yes, I actually took a hacky way to realize it for easy. :) I will consider whether it is feasible to get the config here. If so I will take the config way, otherwise I may add a comment clarifying this.
---