Skip to content

Commit 8393a6a

Browse files
authored
[FLINK-39066][pipeline-connector][Fluss] Fix the metric histogram always return null (#4281)
Co-authored-by: Thorne <syyfffy@163.com>
1 parent 2f59f35 commit 8393a6a

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)