We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 51f4d1f commit dbb7716Copy full SHA for dbb7716
src/stream/src/task/barrier_manager/managed_state.rs
@@ -87,7 +87,9 @@ impl ManagedBarrierState {
87
fn may_notify(&mut self, curr_epoch: u64) {
88
// Report if there's progress on the earliest in-flight barrier.
89
if self.epoch_barrier_state_map.keys().next() == Some(&curr_epoch) {
90
- GLOBAL_STREAMING_METRICS.barrier_manager_progress.inc();
+ if let Some(metrics) = GLOBAL_STREAMING_METRICS.get() {
91
+ metrics.barrier_manager_progress.inc();
92
+ }
93
}
94
95
while let Some(entry) = self.epoch_barrier_state_map.first_entry() {
0 commit comments