diff --git a/src/frontend/src/observer/observer_manager.rs b/src/frontend/src/observer/observer_manager.rs index cc0c4cd93b7f7..88e1b9ff9bdd0 100644 --- a/src/frontend/src/observer/observer_manager.rs +++ b/src/frontend/src/observer/observer_manager.rs @@ -98,7 +98,7 @@ impl ObserverState for FrontendObserverNode { let new_value_empty = new_log.new_value.is_empty(); let old_value_empty = new_log.old_value.is_empty(); if !new_value_empty || !old_value_empty { - Some(TableId::new(table_id.clone())) + Some(TableId::new(*table_id)) } else { None } @@ -219,7 +219,7 @@ impl ObserverState for FrontendObserverNode { if change_log.get_non_empty_epochs(0, usize::MAX).is_empty() { None } else { - Some(table_id.clone()) + Some(*table_id) } }) .collect_vec();