[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r666761438 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -312,6 +323,16 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r666723543 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -312,6 +323,16 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r26886 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -312,6 +323,16 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665933067 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -164,6 +168,27 @@ void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665830690 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionDirectTransferReader.java ## @@ -91,10

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665829387 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -315,6 +326,17 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665814336 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -357,11 +359,26 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665814336 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -357,11 +359,26 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665225932 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -164,6 +168,27 @@ void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665222497 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -315,6 +326,17 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665084877 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -517,19 +539,20 @@ private void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665084629 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -315,6 +326,17 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665082678 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NetworkBufferAllocator.java ## @@ -69,6 +69,9 @@ Buffer

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665080497 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -433,8 +459,8 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665080164 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -433,8 +459,8 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665073463 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -164,6 +168,27 @@ void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665068048 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -357,11 +359,26 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665059027 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionDirectTransferReader.java ## @@ -91,10

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665012443 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -164,6 +168,27 @@ void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r664999767 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -340,7 +355,15 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r664997218 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -340,7 +355,15 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r663591285 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -288,9 +288,7 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662816858 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -288,9 +288,7 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662689103 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -215,9 +221,15 @@ public void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662688120 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -288,9 +288,7 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662020759 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java ## @@ -100,8 +106,19 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662020472 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -357,11 +359,26 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662016156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -357,11 +359,26 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662016156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -357,11 +359,26 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662012667 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -265,6 +265,13 @@ public void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662011666 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -265,6 +265,13 @@ public void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662010444 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -215,9 +221,15 @@ public void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662005533 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -130,11 +136,11 @@ private

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662004311 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -83,8 +84,13 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662003477 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -83,8 +84,13 @@ public

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r662003058 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -513,19 +514,20 @@ private void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661999741 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -513,19 +514,20 @@ private void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661998885 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -288,9 +288,7 @@ BufferAndBacklog

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661993643 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionDirectTransferReader.java ## @@ -110,7

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661992459 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionDirectTransferReader.java ## @@ -91,10

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661990825 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -164,6 +168,27 @@ void

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661986812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -340,7 +355,15 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r661986812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java ## @@ -340,7 +355,15 @@

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r425117136 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java ## @@ -163,8 +172,15 @@