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 df9db31010f [FLINK-37533][CI] Reduce the stale PR github action
timouts to match typical apache values (90 days inactive with 30 to respond)
(#26336)
add 486ba5fe805 [hotfix] Avoid use of raw type parameter in MetricRegistry
interface and implementations.
add fb8f60ef687 [hotfix] Avoid use of raw type parameter in
AbstractMetricGroup.
add 99d66609f3d [hotfix] Avoid use of raw type parameter in
ComponentMetricGroup.
add c12b861c230 [hotfix] Make all fields in SimpleSpan final
add 6ee45494eba [FLINK-37426][metrics] Refactoring to avoid code
duplication in reporter setup code
add 1a274ab2f15 [FLINK-37426][metrics] Properly integrate traces with
metric group features
add 0b3ab69bb4e [FLINK-37426][metrics] Add core support for Events
add ccde5689831 [FLINK-37426][metrics] Integrate EventReporters with
MetricRegistry
add 85e7fc10d73 [FLINK-37426][metrics] Add Slf4jEventReporter
add 0a1af7e7980 [FLINK-37426][metrics] Add OpenTelemetryEventReporter
add 5a911380784 [FLINK-37426][metrics] Regenerate docs
add 0091f39b4a7 [FLINK-37426][metrics] Extract AttributeBuilder interface
No new revisions were added by this update.
Summary of changes:
.../shortcodes/generated/event_configuration.html | 60 +++
.../generated/event_reporters_section.html | 54 ++
.../shortcodes/generated/trace_configuration.html | 24 +
.../generated/trace_reporters_section.html | 24 +
.../flink/annotation/docs/Documentation.java | 2 +
.../flink/configuration/ConfigConstants.java | 6 +
.../apache/flink/configuration/EventOptions.java | 203 ++++++++
.../apache/flink/configuration/TraceOptions.java | 99 +++-
.../java/org/apache/flink/AttributeBuilder.java | 22 +-
.../flink/{traces/Span.java => events/Event.java} | 32 +-
.../java/org/apache/flink/events/EventBuilder.java | 133 +++++
.../java/org/apache/flink/events/SimpleEvent.java | 80 +++
.../flink/events/reporter/EventReporter.java | 18 +-
.../reporter/EventReporterFactory.java} | 13 +-
.../java/org/apache/flink/metrics/MetricGroup.java | 8 +
.../TraceReporter.java => metrics/Reporter.java} | 34 +-
.../flink/metrics/reporter/MetricReporter.java | 24 +-
.../java/org/apache/flink/traces/SimpleSpan.java | 4 +-
.../java/org/apache/flink/traces/SpanBuilder.java | 27 +-
.../flink/traces/reporter/TraceReporter.java | 24 +-
.../events/otel/OpenTelemetryEventReporter.java | 125 +++++
.../otel/OpenTelemetryEventReporterFactory.java} | 15 +-
...ache.flink.events.reporter.EventReporterFactory | 2 +-
.../otel/OpenTelemetryEventReporterTest.java | 169 +++++++
.../slf4j/Slf4jEventReporter.java} | 23 +-
.../slf4j/Slf4jEventReporterFactory.java} | 14 +-
.../flink/traces/slf4j/Slf4jTraceReporter.java | 10 +-
...ache.flink.events.reporter.EventReporterFactory | 2 +-
.../runtime/entrypoint/ClusterEntrypoint.java | 18 +-
.../runtime/metrics/AbstractReporterSetup.java | 106 ++++
.../flink/runtime/metrics/EventReporterSetup.java | 50 ++
.../flink/runtime/metrics/MetricRegistry.java | 10 +-
.../flink/runtime/metrics/MetricRegistryImpl.java | 226 ++++++---
.../flink/runtime/metrics/NoOpMetricRegistry.java | 10 +-
.../flink/runtime/metrics/ReporterSetup.java | 397 +--------------
.../runtime/metrics/ReporterSetupBuilder.java | 560 +++++++++++++++++++++
.../flink/runtime/metrics/TraceReporterSetup.java | 291 +----------
.../metrics/filter/DefaultMetricFilter.java | 129 -----
.../metrics/filter/DefaultReporterFilters.java | 223 ++++++++
.../{MetricFilter.java => ReporterFilter.java} | 25 +-
.../metrics/groups/AbstractMetricGroup.java | 34 +-
.../metrics/groups/ComponentMetricGroup.java | 4 +-
.../runtime/metrics/groups/FrontMetricGroup.java | 7 +-
.../groups/InternalOperatorMetricGroup.java | 2 +-
.../metrics/groups/JobManagerJobMetricGroup.java | 2 +-
.../metrics/groups/JobManagerMetricGroup.java | 2 +-
.../groups/JobManagerOperatorMetricGroup.java | 2 +-
.../runtime/metrics/groups/JobMetricGroup.java | 6 +
.../runtime/metrics/groups/ProxyMetricGroup.java | 6 +
.../metrics/groups/ReporterScopedSettings.java | 10 +-
.../metrics/groups/TaskManagerJobMetricGroup.java | 2 +-
.../metrics/groups/TaskManagerMetricGroup.java | 2 +-
.../runtime/metrics/groups/TaskMetricGroup.java | 2 +-
.../flink/runtime/minicluster/MiniCluster.java | 20 +-
.../runtime/taskexecutor/TaskManagerRunner.java | 18 +-
.../io/network/NettyShuffleEnvironmentTest.java | 2 +-
.../runtime/metrics/CollectingMetricsReporter.java | 4 +-
.../flink/runtime/metrics/EventSetupTest.java | 397 +++++++++++++++
.../runtime/metrics/MetricRegistryImplTest.java | 324 +++++++++++-
.../flink/runtime/metrics/ReporterSetupTest.java | 40 +-
.../flink/runtime/metrics/TraceSetupTest.java | 397 +++++++++++++++
...erTest.java => DefaultReporterFiltersTest.java} | 51 +-
.../metrics/groups/AbstractMetricGroupTest.java | 16 +-
.../metrics/groups/FrontMetricGroupTest.java | 14 +-
.../groups/MetricGroupRegistrationTest.java | 5 +-
.../runtime/metrics/groups/MetricGroupTest.java | 22 +-
.../metrics/groups/TaskMetricGroupTest.java | 4 +-
.../runtime/metrics/util/TestEventReporter.java | 29 +-
.../runtime/metrics/util/TestTraceReporter.java | 20 +-
.../metrics/util/TestingMetricRegistry.java | 37 +-
.../state/forst/ForStNativeMetricMonitorTest.java | 6 +-
.../rocksdb/RocksDBNativeMetricMonitorTest.java | 10 +-
.../runtime/tasks/StreamTaskTestHarness.java | 2 +-
73 files changed, 3637 insertions(+), 1158 deletions(-)
create mode 100644 docs/layouts/shortcodes/generated/event_configuration.html
create mode 100644
docs/layouts/shortcodes/generated/event_reporters_section.html
create mode 100644
flink-core/src/main/java/org/apache/flink/configuration/EventOptions.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/NamedCallback.java
=>
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/AttributeBuilder.java
(57%)
copy
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/{traces/Span.java
=> events/Event.java} (52%)
create mode 100644
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/events/EventBuilder.java
create mode 100644
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/events/SimpleEvent.java
copy
flink-core-api/src/main/java/org/apache/flink/api/common/watermark/WatermarkManager.java
=>
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/events/reporter/EventReporter.java
(70%)
copy
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/{traces/reporter/TraceReporterFactory.java
=> events/reporter/EventReporterFactory.java} (82%)
copy
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/{traces/reporter/TraceReporter.java
=> metrics/Reporter.java} (57%)
create mode 100644
flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/events/otel/OpenTelemetryEventReporter.java
copy
flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/{traces/otel/OpenTelemetryTraceReporterFactory.java
=> events/otel/OpenTelemetryEventReporterFactory.java} (69%)
copy
flink-clients/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
=>
flink-metrics/flink-metrics-otel/src/main/resources/META-INF/services/org.apache.flink.events.reporter.EventReporterFactory
(92%)
create mode 100644
flink-metrics/flink-metrics-otel/src/test/java/org/apache/flink/metrics/otel/OpenTelemetryEventReporterTest.java
copy
flink-metrics/flink-metrics-slf4j/src/main/java/org/apache/flink/{traces/slf4j/Slf4jTraceReporter.java
=> events/slf4j/Slf4jEventReporter.java} (75%)
copy
flink-metrics/flink-metrics-slf4j/src/main/java/org/apache/flink/{traces/slf4j/Slf4jTraceReporterFactory.java
=> events/slf4j/Slf4jEventReporterFactory.java} (67%)
copy
flink-clients/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
=>
flink-metrics/flink-metrics-slf4j/src/main/resources/META-INF/services/org.apache.flink.events.reporter.EventReporterFactory
(93%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/AbstractReporterSetup.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/EventReporterSetup.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetupBuilder.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/filter/DefaultMetricFilter.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/filter/DefaultReporterFilters.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/filter/{MetricFilter.java
=> ReporterFilter.java} (57%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/EventSetupTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/TraceSetupTest.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/filter/{DefaultMetricFilterTest.java
=> DefaultReporterFiltersTest.java} (77%)
copy
flink-metrics/flink-metrics-slf4j/src/main/java/org/apache/flink/traces/slf4j/Slf4jTraceReporter.java
=>
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/TestEventReporter.java
(61%)
copy
flink-metrics/flink-metrics-otel/src/main/java/org/apache/flink/traces/otel/OpenTelemetryTraceReporterFactory.java
=>
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/TestTraceReporter.java
(69%)
