Piotr Nowojski

[FLINK-33697][state][metrics] Trace RocksDBIncremental remote files download time

4

This PR builds on top of https://github.com/apache/flink/pull/23908 ## Brief change log Please check individual commit messages ## Verifying this change This change has been manually tested and added a unit...

[hotfix] Fix missing flink-end-to-end-tests-jdbc-driver dependency

1

## Brief change log This PR fixes IntelliJ errors when trying to compile `flink-end-to-end-tests-jdbc-driver` due to not declared dependencies to `flink-core` for example. ## Verifying this change This change is...

[FLINK-32828][1.19] Partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

1

This is a backport of https://github.com/apache/flink/pull/24794 to 1.19 ## What is the purpose of the change Properly initialize initial splits in WatermarkOutputMultiplexer Without this fix, initial splits were registered in...

[FLINK-32828][1.18] Partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

1

This is a backport of https://github.com/apache/flink/pull/24794 to 1.18 ## What is the purpose of the change Properly initialize initial splits in WatermarkOutputMultiplexer Without this fix, initial splits were registered in...

[FLINK-33696][metrics] Add OpenTelemetryMetricReporter and OpenTelemetryTraceReporter

2

## What is the purpose of the change This adds support for reporting metrics and traces to OpenTelemetry using gRPC. ## Brief change log Please check individual commit messages. ##...