handle v2

risingwavelabs · Aug 7, 2024 · 23cb77e · 23cb77e
1 parent e372293
commit 23cb77e
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/meta/src/controller/streaming_job.rs b/src/meta/src/controller/streaming_job.rs
@@ -1214,12 +1214,22 @@ impl CatalogController {
         let inner = self.inner.read().await;
         let txn = inner.db.begin().await?;
 
+        {
+            let job = streaming_job::ActiveModel {
+                job_id: Set(source_id),
+                job_status: Set(JobStatus::Created),
+                ..Default::default()
+            };
+            job.update(&txn).await?;
+        }
+
         let source = Source::find_by_id(source_id)
             .one(&txn)
             .await?
             .ok_or_else(|| {
                 MetaError::catalog_id_not_found(ObjectType::Source.as_str(), source_id)
             })?;
+
         let streaming_job_ids: Vec<ObjectId> =
             if let Some(table_id) = source.optional_associated_table_id {
                 vec![table_id]