fix(meta): fix backwards compat issues for Table::stream_job_status…

… field (#12434)
risingwavelabs · Sep 19, 2023 · 7324a95 · 7324a95
1 parent 5cd4082
commit 7324a95
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/src/meta/src/manager/catalog/database.rs b/src/meta/src/manager/catalog/database.rs
@@ -149,18 +149,27 @@ impl DatabaseManager {
             self.schemas.values().cloned().collect_vec(),
             self.tables
                 .values()
-                .filter(|t| t.stream_job_status == PbStreamJobStatus::Created as i32)
+                .filter(|t| {
+                    t.stream_job_status == PbStreamJobStatus::Unspecified as i32
+                        || t.stream_job_status == PbStreamJobStatus::Created as i32
+                })
                 .cloned()
                 .collect_vec(),
             self.sources.values().cloned().collect_vec(),
             self.sinks
                 .values()
-                .filter(|s| s.stream_job_status == PbStreamJobStatus::Created as i32)
+                .filter(|t| {
+                    t.stream_job_status == PbStreamJobStatus::Unspecified as i32
+                        || t.stream_job_status == PbStreamJobStatus::Created as i32
+                })
                 .cloned()
                 .collect_vec(),
             self.indexes
                 .values()
-                .filter(|i| i.stream_job_status == PbStreamJobStatus::Created as i32)
+                .filter(|t| {
+                    t.stream_job_status == PbStreamJobStatus::Unspecified as i32
+                        || t.stream_job_status == PbStreamJobStatus::Created as i32
+                })
                 .cloned()
                 .collect_vec(),
             self.views.values().cloned().collect_vec(),

diff --git a/src/meta/src/rpc/service/notification_service.rs b/src/meta/src/rpc/service/notification_service.rs
@@ -124,7 +124,10 @@ impl NotificationServiceImpl {
             .database
             .list_tables()
             .into_iter()
-            .filter(|t| t.stream_job_status == PbStreamJobStatus::Created as i32)
+            .filter(|t| {
+                t.stream_job_status == PbStreamJobStatus::Unspecified as i32
+                    || t.stream_job_status == PbStreamJobStatus::Created as i32
+            })
             .collect_vec();
         tables.extend(catalog_guard.database.list_creating_tables());
         let notification_version = self.env.notification_manager().current_version().await;