[flink] branch master updated: [FLINK-24738][runtime] Ignoring buffer size announcement if the subpartition view has not created yet

[dwysakowicz]

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 60a73fa  [FLINK-24738][runtime] Ignoring buffer size announcement if 
the subpartition view has not created yet
60a73fa is described below

commit 60a73fa88bf8589f00f1c0be6980ef0703808f21
Author: Anton Kalashnikov <kaa....@yandex.ru>
AuthorDate: Mon Nov 8 18:10:16 2021 +0100

    [FLINK-24738][runtime] Ignoring buffer size announcement if the 
subpartition view has not created yet
---
 .../runtime/io/network/partition/consumer/LocalInputChannel.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
index 120ffe9..13c6538 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
@@ -340,8 +340,10 @@ public class LocalInputChannel extends InputChannel 
implements BufferAvailabilit
     void announceBufferSize(int newBufferSize) {
         checkState(!isReleased, "Channel released.");
 
-        ResultSubpartitionView subpartitionView = 
checkNotNull(this.subpartitionView);
-        subpartitionView.notifyNewBufferSize(newBufferSize);
+        ResultSubpartitionView view = this.subpartitionView;
+        if (view != null) {
+            view.notifyNewBufferSize(newBufferSize);
+        }
     }
 
     @Override