fix check ci

risingwavelabs · Sep 14, 2024 · 4b01cf7 · 4b01cf7
1 parent 668ab21
commit 4b01cf7
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/proto/meta.proto b/proto/meta.proto
@@ -821,11 +821,11 @@ service ClusterLimitService {
   rpc GetClusterLimits(GetClusterLimitsRequest) returns (GetClusterLimitsResponse);
 }
 
-
 message ChangeLogEpochs {
   message Uint64List {
     repeated uint64 epochs = 1;
     uint64 truncate_epoch = 2;
   }
   map<uint32, Uint64List> change_log_epochs = 1;
+
 }
diff --git a/src/frontend/src/catalog/root_catalog.rs b/src/frontend/src/catalog/root_catalog.rs
@@ -232,6 +232,8 @@ impl Catalog {
                 .change_log_epochs_by_table_id
                 .entry(TableId::new(*table_id))
                 .or_default();
+
+            // Ensure the epochs in the queue are in order
             if let Some(save_max_epoch) = epochs_entry.back()
                 && let Some(delta_min_epoch) = change_log_epochs.epochs.first()
             {

diff --git a/src/storage/hummock_sdk/src/change_log.rs b/src/storage/hummock_sdk/src/change_log.rs
@@ -125,6 +125,7 @@ impl TableChangeLog {
     }
 }
 
+// Get `change_log_epochs` from `change_log_delta` who will be used to update the epoch list of subscriptions saved in the frontend
 pub fn build_change_log_epochs_from_delta(
     change_log_delta: &HashMap<TableId, ChangeLogDelta>,
 ) -> ChangeLogEpochs {