This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 60aa2ac [refactor][runtime] Added postfix `unsafe` for methods
ResultSubpartition#getTotalNumberOfBuffers and
ResultSubpartition#getTotalNumberOfBytes
add dfad1d5 [refactor][runtime] Removed extra methods for optimization of
calculation of absoluteTimeMillis for ThroughputCalculator since they haven't
been used anymore
add 7ccd525 [FLINK-25454][runtime] Pause and resume time for throughput
calculator only from one thread.
No new revisions were added by this update.
Summary of changes:
.../partition/consumer/SingleInputGate.java | 9 +++----
.../apache/flink/runtime/metrics/TimerGauge.java | 30 +++-------------------
.../runtime/throughput/ThroughputCalculator.java | 22 +++++-----------
.../throughput/ThroughputCalculatorTest.java | 12 ++++-----
4 files changed, 18 insertions(+), 55 deletions(-)
