pnowojski commented on a change in pull request #16726:
URL: https://github.com/apache/flink/pull/16726#discussion_r686710790
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##########
@@ -396,12 +397,13 @@ protected StreamTask(
environment.getMetricGroup().getIOMetricGroup().setEnableBusyTime(true);
this.throughputCalculator = environment.getThroughputCalculator();
- this.bufferDebloatPeriod =
getTaskConfiguration().get(BUFFER_DEBLOAT_PERIOD).toMillis();
+ Configuration taskManagerConf =
environment.getTaskManagerInfo().getConfiguration();
Review comment:
Can you create a separate jira ticket for this bug fix (as this bug is
already on the master)? This fix can stay in this PR, but can you adjust it's
commit message to match the crated ticket?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
