You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by pn...@apache.org on 2021/12/31 10:30:57 UTC

[flink] branch master updated (60aa2ac -> 7ccd525)

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(-)