This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 8393a6a43 [FLINK-39066][pipeline-connector][Fluss] Fix the metric
histogram always return null (#4281)
8393a6a43 is described below
commit 8393a6a435f2b2304a78535fbaac2194c0c683f9
Author: Thorne <[email protected]>
AuthorDate: Tue Feb 24 17:28:54 2026 +0800
[FLINK-39066][pipeline-connector][Fluss] Fix the metric histogram always
return null (#4281)
Co-authored-by: Thorne <[email protected]>
---
.../cdc/connectors/fluss/sink/v2/metrics/WrapperFlussHistogram.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussHistogram.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussHistogram.java
index a6ce22838..a62a646a3 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussHistogram.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussHistogram.java
@@ -45,10 +45,7 @@ public class WrapperFlussHistogram implements Histogram {
@Override
public HistogramStatistics getStatistics() {
-
- flussHistogram.getStatistics();
-
- return null;
+ return new FlinkHistogramStatistics(flussHistogram.getStatistics());
}
private static class FlinkHistogramStatistics extends HistogramStatistics {
