Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions docs/docs/flink-writes.md
Original file line number Diff line number Diff line change
Expand Up @@ -210,6 +210,10 @@ They should have the following key-value tags.
| dataFilesSizeHistogram | Histogram | Histogram distribution of data file sizes (in bytes). |
| deleteFilesSizeHistogram | Histogram | Histogram distribution of delete file sizes (in bytes). |

The `Histogram` metrics above require `flink-metrics-dropwizard` on the classpath, which is not shipped
by Flink by default. When using `iceberg-flink-runtime`, this dependency is already bundled. When using
the `iceberg-flink` artifact directly, add `org.apache.flink:flink-metrics-dropwizard` as a dependency.

Committer metrics are added under the sub group of `IcebergFilesCommitter`.
They should have the following key-value tags.

Expand Down
4 changes: 2 additions & 2 deletions flink/v1.19/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ project(":iceberg-flink:iceberg-flink-${flinkMajorVersion}") {
implementation project(':iceberg-hive-metastore')

compileOnly libs.flink119.avro
// for dropwizard histogram metrics implementation
// dropwizard histogram metrics (optional in Flink)
compileOnly libs.flink119.metrics.dropwizard
compileOnly libs.flink119.streaming.java
compileOnly "${libs.flink119.streaming.java.get().module}:${libs.flink119.streaming.java.get().getVersion()}:tests"
Expand Down Expand Up @@ -168,7 +168,7 @@ project(":iceberg-flink:iceberg-flink-runtime-${flinkMajorVersion}") {
exclude group: 'com.google.code.findbugs', module: 'jsr305'
}

// for dropwizard histogram metrics implementation
// To support dropwizard histogram metrics (not shipped by Flink by default)
implementation libs.flink119.metrics.dropwizard

// for integration testing with the flink-runtime-jar
Expand Down
11 changes: 9 additions & 2 deletions flink/v1.19/flink-runtime/LICENSE
Original file line number Diff line number Diff line change
Expand Up @@ -461,11 +461,18 @@ License: https://www.apache.org/licenses/LICENSE-2.0.html

--------------------------------------------------------------------------------

This binary artifact contains Codehale Metrics.
This product bundles Dropwizard Metrics.

Copyright: (c) 2010-2013 Coda Hale, Yammer.com, 2014-2021 Dropwizard Team
Home page: https://github.com/dropwizard/metrics
License: https://www.apache.org/licenses/LICENSE-2.0.html
License: Apache License, Version 2.0 - https://www.apache.org/licenses/LICENSE-2.0

--------------------------------------------------------------------------------

This product bundles Apache Flink's optional support for Dropwizard Metrics.

Copyright: 2014-2026 The Apache Software Foundation
Project URL: https://flink.apache.org/

--------------------------------------------------------------------------------

Expand Down
4 changes: 2 additions & 2 deletions flink/v1.20/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ project(":iceberg-flink:iceberg-flink-${flinkMajorVersion}") {
implementation project(':iceberg-hive-metastore')

compileOnly libs.flink120.avro
// for dropwizard histogram metrics implementation
// dropwizard histogram metrics (optional in Flink)
compileOnly libs.flink120.metrics.dropwizard
compileOnly libs.flink120.streaming.java
compileOnly "${libs.flink120.streaming.java.get().module}:${libs.flink120.streaming.java.get().getVersion()}:tests"
Expand Down Expand Up @@ -168,7 +168,7 @@ project(":iceberg-flink:iceberg-flink-runtime-${flinkMajorVersion}") {
exclude group: 'com.google.code.findbugs', module: 'jsr305'
}

// for dropwizard histogram metrics implementation
// To support dropwizard histogram metrics (not shipped by Flink by default)
implementation libs.flink120.metrics.dropwizard

// for integration testing with the flink-runtime-jar
Expand Down
11 changes: 9 additions & 2 deletions flink/v1.20/flink-runtime/LICENSE
Original file line number Diff line number Diff line change
Expand Up @@ -461,11 +461,18 @@ License: https://www.apache.org/licenses/LICENSE-2.0.html

--------------------------------------------------------------------------------

This binary artifact contains Codehale Metrics.
This product bundles Dropwizard Metrics.

Copyright: (c) 2010-2013 Coda Hale, Yammer.com, 2014-2021 Dropwizard Team
Home page: https://github.com/dropwizard/metrics
License: https://www.apache.org/licenses/LICENSE-2.0.html
License: Apache License, Version 2.0 - https://www.apache.org/licenses/LICENSE-2.0

--------------------------------------------------------------------------------

This product bundles Apache Flink's optional support for Dropwizard Metrics.

Copyright: 2014-2026 The Apache Software Foundation
Project URL: https://flink.apache.org/

--------------------------------------------------------------------------------

Expand Down
4 changes: 2 additions & 2 deletions flink/v2.0/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ project(":iceberg-flink:iceberg-flink-${flinkMajorVersion}") {
implementation project(':iceberg-hive-metastore')

compileOnly libs.flink20.avro
// for dropwizard histogram metrics implementation
// dropwizard histogram metrics (optional in Flink)
compileOnly libs.flink20.metrics.dropwizard
compileOnly libs.flink20.streaming.java
compileOnly "${libs.flink20.streaming.java.get().module}:${libs.flink20.streaming.java.get().getVersion()}:tests"
Expand Down Expand Up @@ -168,7 +168,7 @@ project(":iceberg-flink:iceberg-flink-runtime-${flinkMajorVersion}") {
exclude group: 'com.google.code.findbugs', module: 'jsr305'
}

// for dropwizard histogram metrics implementation
// To support dropwizard histogram metrics (not shipped by Flink by default)
implementation libs.flink20.metrics.dropwizard

// for integration testing with the flink-runtime-jar
Expand Down
11 changes: 9 additions & 2 deletions flink/v2.0/flink-runtime/LICENSE
Original file line number Diff line number Diff line change
Expand Up @@ -461,11 +461,18 @@ License: https://www.apache.org/licenses/LICENSE-2.0.html

--------------------------------------------------------------------------------

This binary artifact contains Codehale Metrics.
This product bundles Dropwizard Metrics.

Copyright: (c) 2010-2013 Coda Hale, Yammer.com, 2014-2021 Dropwizard Team
Home page: https://github.com/dropwizard/metrics
License: https://www.apache.org/licenses/LICENSE-2.0.html
License: Apache License, Version 2.0 - https://www.apache.org/licenses/LICENSE-2.0

--------------------------------------------------------------------------------

This product bundles Apache Flink's optional support for Dropwizard Metrics.

Copyright: 2014-2026 The Apache Software Foundation
Project URL: https://flink.apache.org/

--------------------------------------------------------------------------------

Expand Down
Loading