This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ad5dcb2 [FLINK-23467][e2e] Remove usage of the sql-client YAML file
in pyflink.sh
add b4244e1 [hotfix][metrics] Rename MinMaxAvgStats to StatsSummary
add e6085a8 [hotfix][metrics] Introduce immutable snapshots for
checkpoint stats
add 4a10a1e [hotfix][tests] De-duplicate code in
ArchivedExecutionGraphTest
add 329bed8 [FLINK-23144][metrics] Add percentiles to checkpoint
statistics
No new revisions were added by this update.
Summary of changes:
.../src/test/resources/rest_api_v1.snapshot | 60 ++++++--
.../src/app/interfaces/job-checkpoint.ts | 5 +
.../job/checkpoints/job-checkpoints.component.html | 71 ++++++++-
.../job/checkpoints/job-checkpoints.component.ts | 2 +
.../checkpoint/CheckpointStatsSnapshot.java | 8 +-
.../CompletedCheckpointStatsSummary.java | 42 +++---
.../CompletedCheckpointStatsSummarySnapshot.java | 70 +++++++++
.../{MinMaxAvgStats.java => StatsSummary.java} | 40 +++--
.../runtime/checkpoint/StatsSummarySnapshot.java | 110 ++++++++++++++
.../flink/runtime/checkpoint/TaskStateStats.java | 32 ++--
.../metrics/DescriptiveStatisticsHistogram.java | 9 +-
.../DescriptiveStatisticsHistogramStatistics.java | 9 +-
.../CheckpointingStatisticsHandler.java | 17 +--
.../TaskCheckpointStatisticDetailsHandler.java | 32 ++--
.../checkpoints/CheckpointingStatistics.java | 24 +--
.../messages/checkpoints/MinMaxAvgStatistics.java | 88 -----------
.../rest/messages/checkpoints/StatsSummaryDto.java | 163 +++++++++++++++++++++
...TaskCheckpointStatisticsWithSubtaskDetails.java | 55 ++++---
.../checkpoint/CheckpointStatsSnapshotTest.java | 2 +-
.../checkpoint/CheckpointStatsTrackerTest.java | 4 +-
.../CompletedCheckpointStatsSummaryTest.java | 40 ++++-
...nMaxAvgStatsTest.java => StatsSummaryTest.java} | 23 ++-
.../executiongraph/ArchivedExecutionGraphTest.java | 54 ++++---
.../checkpoints/CheckpointingStatisticsTest.java | 10 +-
...CheckpointStatisticsWithSubtaskDetailsTest.java | 18 +--
25 files changed, 716 insertions(+), 272 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStatsSummarySnapshot.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/{MinMaxAvgStats.java
=> StatsSummary.java} (69%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StatsSummarySnapshot.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/MinMaxAvgStatistics.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/StatsSummaryDto.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/{MinMaxAvgStatsTest.java
=> StatsSummaryTest.java} (80%)
