filter out shared streaming source

risingwavelabs · Sep 3, 2024 · 1854392 · 1854392
1 parent 7d942ba
commit 1854392
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/meta/src/manager/catalog/mod.rs b/src/meta/src/manager/catalog/mod.rs
@@ -629,11 +629,12 @@ impl CatalogManager {
                 .into_iter()
                 .filter(|table| valid_table_name(&table.name))
                 .map(|table| StreamingJobId::new(table.id))
-                .chain(
-                    sources_to_drop
-                        .iter()
-                        .map(|source| StreamingJobId::new(source.id)),
-                )
+                .chain(sources_to_drop.iter().filter_map(|source| {
+                    source
+                        .info
+                        .as_ref()
+                        .and_then(|info| info.is_shared().then(|| StreamingJobId::new(source.id)))
+                }))
                 .chain(
                     sinks_to_drop
                         .into_iter()