[flink] branch release-1.14 updated: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager configuration instead of task configuration

[yu...@apache.org]

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

yuanmei pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new 3e341d0  [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager configuration instead of task configuration
3e341d0 is described below

commit 3e341d01ca7c5ad498d4d0b5e90d4206a79c3cb5
Author: Anton Kalashnikov <ka...@yandex.ru>
AuthorDate: Mon Nov 1 13:00:20 2021 +0100

    [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager configuration instead of task configuration
---
 .../src/main/java/org/apache/flink/runtime/taskmanager/Task.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
index f24988c..8ccb0ac 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
@@ -423,7 +423,7 @@ public class Task
         this.inputGates = new IndexedInputGate[gates.length];
         this.throughputCalculator =
                 new ThroughputCalculator(
-                        SystemClock.getInstance(), taskConfiguration.get(BUFFER_DEBLOAT_SAMPLES));
+                        SystemClock.getInstance(), tmConfig.get(BUFFER_DEBLOAT_SAMPLES));
         int counter = 0;
         for (IndexedInputGate gate : gates) {
             inputGates[counter++] =