This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from bc583b41586 [HUDI-6609] Reverting multi writer checkpointing with
HoodieStreamer (#9312)
add ade9d0bcb9d [HUDI-2141] Support flink read metrics (#9350)
No new revisions were added by this update.
Summary of changes:
hudi-flink-datasource/hudi-flink/pom.xml | 6 ++
.../hudi/metrics/FlinkStreamReadMetrics.java | 96 ++++++++++++++++++++++
.../apache/hudi/metrics/HoodieFlinkMetrics.java} | 29 +++----
.../hudi/source/StreamReadMonitoringFunction.java | 13 +++
.../org/apache/hudi/source/StreamReadOperator.java | 14 ++++
packaging/hudi-flink-bundle/pom.xml | 6 ++
6 files changed, 146 insertions(+), 18 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkStreamReadMetrics.java
copy
hudi-flink-datasource/hudi-flink/src/{test/java/org/apache/hudi/sink/utils/ScalaCollector.java
=> main/java/org/apache/hudi/metrics/HoodieFlinkMetrics.java} (62%)
