[
https://issues.apache.org/jira/browse/FLINK-24467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-24467.
------------------------------------
Fix Version/s: 1.14.1
1.15.0
Resolution: Fixed
Implemented in:
* master
**
747895f1bde53f358df9517e0313c679cb4151bc..58197bebb554df7df1dd3dc27cc3e71cc3ad5b49
* 1.14
**
28690757444e63d67eb3cdcba0c4fb2f99d9d8e4..1cd2a749d6f7a48a2c0e901438c47d2510a628cf
> Set min and max buffer size even if the difference less than threshold
> ----------------------------------------------------------------------
>
> Key: FLINK-24467
> URL: https://issues.apache.org/jira/browse/FLINK-24467
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.14.0
> Reporter: Anton Kalashnikov
> Assignee: Anton Kalashnikov
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0, 1.14.1
>
>
> Right now, we apply a new buffer size only if it differs from the old buffer
> size more than the configured threshold but if the old buffer size is close
> to the max or min value less than this threshold we are always stuck on this
> value. For example, if we have the old buffer size 22k and our threshold is
> 50% then the value which we can apply should 33k but this is impossible
> because the max value is 32k so once we calculate the buffer size to 22k it
> is impossible to increase it.
> The suggestion is to apply the changes every time when we calculate the new
> value to min or max size and the old value was different.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
