Skip to content

Commit e097ae2

Browse files
committed
fix the metric histogram of fluss connector with FlinkHistogramStatistics class without always return null
1 parent 0cfe1d3 commit e097ae2

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,10 +45,7 @@ public long getCount() {
4545

4646
@Override
4747
public HistogramStatistics getStatistics() {
48-
49-
flussHistogram.getStatistics();
50-
51-
return null;
48+
return new FlinkHistogramStatistics(flussHistogram.getStatistics());
5249
}
5350

5451
private static class FlinkHistogramStatistics extends HistogramStatistics {

0 commit comments

Comments
 (0)