fix: Add read guard on reschedule_lock for drop_streaming_jobs (#20240

) Signed-off-by: Shanicky Chen <[email protected]>
risingwavelabs · Jan 22, 2025 · 2003863 · 2003863
1 parent 7c4e1b8
commit 2003863
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs
@@ -1480,6 +1480,8 @@ impl DdlController {
         drop_mode: DropMode,
         target_replace_info: Option<ReplaceTableInfo>,
     ) -> MetaResult<NotificationVersion> {
+        let _reschedule_job_lock = self.stream_manager.reschedule_lock_read_guard().await;
+
         let (object_id, object_type) = match job_id {
             StreamingJobId::MaterializedView(id) => (id as _, ObjectType::Table),
             StreamingJobId::Sink(id) => (id as _, ObjectType::Sink),