Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
chenzl25 committed Sep 28, 2023
1 parent 04ef7cd commit 79dd75c
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions src/stream/src/from_proto/sink.rs
Original file line number Diff line number Diff line change
Expand Up @@ -105,10 +105,7 @@ impl ExecutorBuilder for SinkExecutorBuilder {
let connector_sink_rows_received = stream
.streaming_metrics
.connector_sink_rows_received
.with_label_values(&[
connector,
&sink_param.sink_id.sink_id.to_string(),
]);
.with_label_values(&[connector, &sink_param.sink_id.sink_id.to_string()]);

let sink_metrics = SinkMetrics {
sink_commit_duration_metrics,
Expand Down

0 comments on commit 79dd75c

Please sign in to comment.