This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ca770b3d905 [FLINK-31099][python] Fix chained WindowOperator throws
NPE in PyFlink Thread Mode
add 7bebd2d9fac [FLINK-29801][metrics] Add OperatorCoordinator metric group
No new revisions were added by this update.
Summary of changes:
.../shortcodes/generated/metric_configuration.html | 6 +
.../apache/flink/configuration/MetricOptions.java | 11 ++
flink-docs/README.md | 2 +-
.../runtime/executiongraph/ExecutionJobVertex.java | 23 +--
.../SpeculativeExecutionJobVertex.java | 2 +-
.../metrics/dump/MetricDumpSerialization.java | 17 +-
.../flink/runtime/metrics/dump/QueryScopeInfo.java | 35 ++++
.../InternalOperatorCoordinatorMetricGroup.java | 19 +-
.../metrics/groups/JobManagerJobMetricGroup.java | 64 ++++++-
...oup.java => JobManagerOperatorMetricGroup.java} | 80 ++++----
.../metrics/groups/UnregisteredMetricGroups.java | 40 ++++
...mat.java => JobManagerOperatorScopeFormat.java} | 34 ++--
.../flink/runtime/metrics/scope/ScopeFormats.java | 18 +-
.../coordination/OperatorCoordinator.java | 4 +
.../coordination/OperatorCoordinatorHolder.java | 47 ++++-
.../RecreateOnResetOperatorCoordinator.java | 6 +
.../rest/handler/legacy/metrics/MetricStore.java | 30 ++-
.../DefaultOperatorCoordinatorHandler.java | 14 +-
.../scheduler/OperatorCoordinatorHandler.java | 8 +-
.../flink/runtime/scheduler/SchedulerBase.java | 3 +-
.../scheduler/adaptive/AdaptiveScheduler.java | 8 +
.../scheduler/adaptive/CreatingExecutionGraph.java | 10 +-
.../adaptivebatch/AdaptiveBatchScheduler.java | 4 +-
.../metrics/dump/MetricDumpSerializerTest.java | 44 +++--
.../runtime/metrics/dump/QueryScopeInfoTest.java | 34 ++++
.../InternalOperatorCoordinatorGroupTest.java | 86 +++++++++
.../groups/JobManagerOperatorGroupTest.java | 211 +++++++++++++++++++++
.../MockOperatorCoordinatorContext.java | 9 +
.../OperatorCoordinatorHolderTest.java | 21 +-
.../handler/legacy/metrics/MetricFetcherTest.java | 13 ++
.../handler/legacy/metrics/MetricStoreTest.java | 24 ++-
.../DefaultOperatorCoordinatorHandlerTest.java | 5 +-
.../adaptive/CreatingExecutionGraphTest.java | 7 +
.../TestingOperatorCoordinatorHandler.java | 8 +-
34 files changed, 809 insertions(+), 138 deletions(-)
copy
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/exceptions/UnknownLocationException.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/InternalOperatorCoordinatorMetricGroup.java
(63%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/{InternalOperatorMetricGroup.java
=> JobManagerOperatorMetricGroup.java} (55%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/{TaskScopeFormat.java
=> JobManagerOperatorScopeFormat.java} (65%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/InternalOperatorCoordinatorGroupTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/JobManagerOperatorGroupTest.java
