You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tv...@apache.org on 2023/10/24 17:18:36 UTC
[beam] branch master updated (bc06581e110 -> 8a2ed4d7f56)
This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from bc06581e110 Enable run test on Java 21 (#28969)
add b332eeb2901 Add MetricsContainer support to the Flink sources.
add 3f2c5e76c07 Favor composition in FlinkMetricsContainer implementations
add 36ba537c6c2 Fix Guava import
new 8a2ed4d7f56 Add MetricsContainer support to the Flink sources. #28609
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../streaming/io/source/SourceTestCompat.java | 13 ++
.../streaming/io/source/SourceTestCompat.java | 13 ++
.../beam/runners/flink/FlinkRunnerResult.java | 4 +-
.../flink/metrics/FlinkMetricContainer.java | 160 +--------------------
...ontainer.java => FlinkMetricContainerBase.java} | 74 +++-------
.../FlinkMetricContainerWithoutAccumulator.java} | 15 +-
.../flink/metrics/ReaderInvocationUtil.java | 4 +-
.../wrappers/streaming/io/source/FlinkSource.java | 12 +-
.../streaming/io/source/FlinkSourceReaderBase.java | 13 +-
.../io/source/bounded/FlinkBoundedSource.java | 8 +-
.../source/bounded/FlinkBoundedSourceReader.java | 10 +-
.../io/source/unbounded/FlinkUnboundedSource.java | 13 +-
.../unbounded/FlinkUnboundedSourceReader.java | 6 +-
.../flink/metrics/FlinkMetricContainerTest.java | 2 +-
.../wrappers/streaming/io/TestCountingSource.java | 7 +
.../io/source/FlinkSourceReaderTestBase.java | 28 ++++
.../bounded/FlinkBoundedSourceReaderTest.java | 5 +-
.../unbounded/FlinkUnboundedSourceReaderTest.java | 5 +-
18 files changed, 151 insertions(+), 241 deletions(-)
copy runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/{FlinkMetricContainer.java => FlinkMetricContainerBase.java} (70%)
copy runners/flink/{1.12/src/test/java/org/apache/beam/runners/flink/metrics/MetricGroupWrapper.java => src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainerWithoutAccumulator.java} (62%)
[beam] 01/01: Add MetricsContainer support to the Flink sources. #28609
Posted by tv...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 8a2ed4d7f56234a232a42485f6c83c42943b52c0
Merge: bc06581e110 36ba537c6c2
Author: tvalentyn <tv...@users.noreply.github.com>
AuthorDate: Tue Oct 24 10:18:28 2023 -0700
Add MetricsContainer support to the Flink sources. #28609
Co-authored-by: Jiangjie Qin <jq...@jqin-mn1.internal.linkedin.cn>
.../streaming/io/source/SourceTestCompat.java | 13 ++
.../streaming/io/source/SourceTestCompat.java | 13 ++
.../beam/runners/flink/FlinkRunnerResult.java | 4 +-
.../flink/metrics/FlinkMetricContainer.java | 160 +--------------------
...ontainer.java => FlinkMetricContainerBase.java} | 74 +++-------
.../FlinkMetricContainerWithoutAccumulator.java | 34 +++++
.../flink/metrics/ReaderInvocationUtil.java | 4 +-
.../wrappers/streaming/io/source/FlinkSource.java | 12 +-
.../streaming/io/source/FlinkSourceReaderBase.java | 13 +-
.../io/source/bounded/FlinkBoundedSource.java | 8 +-
.../source/bounded/FlinkBoundedSourceReader.java | 10 +-
.../io/source/unbounded/FlinkUnboundedSource.java | 13 +-
.../unbounded/FlinkUnboundedSourceReader.java | 6 +-
.../flink/metrics/FlinkMetricContainerTest.java | 2 +-
.../wrappers/streaming/io/TestCountingSource.java | 7 +
.../io/source/FlinkSourceReaderTestBase.java | 28 ++++
.../bounded/FlinkBoundedSourceReaderTest.java | 5 +-
.../unbounded/FlinkUnboundedSourceReaderTest.java | 5 +-
18 files changed, 176 insertions(+), 235 deletions(-)