Skip to content

Commit b572d6c

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

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)