fix ci

fix

fix

fix

fix

fix

fix

src/meta/src/controller/catalog.rs

@@ -482,16 +482,19 @@ impl CatalogController {
             .one(&txn)
             .await?
             .ok_or_else(|| MetaError::catalog_id_not_found("subscription", job_id))?;
+        txn.commit().await?;
 
-        let relations = vec![PbRelation {
-            relation_info: Some(PbRelationInfo::Subscription(
-                ObjectModel(subscription, obj.unwrap()).into(),
-            )),
-        }];
         let version = self
             .notify_frontend(
-                NotificationOperation::Add,
-                NotificationInfo::RelationGroup(PbRelationGroup { relations }),
+                Operation::Add,
+                Info::RelationGroup(PbRelationGroup {
+                    relations: vec![PbRelation {
+                        relation_info: PbRelationInfo::Subscription(
+                            ObjectModel(subscription, obj.unwrap()).into(),
+                        )
+                        .into(),
+                    }],
+                }),
             )
             .await;
         Ok(version)

src/meta/src/manager/notification.rs

@@ -101,7 +101,6 @@ impl NotificationManager {
                     info: Some(task.info),
                     version: task.version.unwrap_or_default(),
                 };
-
                 core.lock().await.notify(task.target, response);
             }
         });

src/storage/hummock_sdk/src/change_log.rs

@@ -39,6 +39,7 @@ impl TableChangeLog {
             .filter_epoch((min_epoch, u64::MAX))
             .iter()
             .flat_map(|epoch_change_log| epoch_change_log.epochs.clone())
+            .filter(|a| a >= &min_epoch)
             .clone()
             .collect();
         let end = min(max_count, epochs.len());