Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141380483 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -169,95 +182,19 @@ public void testCancelBeforeActive() throws Exception { client.cancelRequestFor(inputChannel.getInputChannelId()); } - /** - * Tests that an unsuccessful message decode call for a staged message - * does not leave the channel with auto read set to false. - */ - @Test - @SuppressWarnings("unchecked") - public void testAutoReadAfterUnsuccessfulStagedMessage() throws Exception { --- End diff -- I will consider it
---