Skip to content

Commit

Permalink
fix check ci
Browse files Browse the repository at this point in the history
fix
  • Loading branch information
xxhZs committed Sep 14, 2024
1 parent 668ab21 commit 971207d
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 1 deletion.
1 change: 0 additions & 1 deletion proto/meta.proto
Original file line number Diff line number Diff line change
Expand Up @@ -821,7 +821,6 @@ service ClusterLimitService {
rpc GetClusterLimits(GetClusterLimitsRequest) returns (GetClusterLimitsResponse);
}


message ChangeLogEpochs {
message Uint64List {
repeated uint64 epochs = 1;
Expand Down
2 changes: 2 additions & 0 deletions src/frontend/src/catalog/root_catalog.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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()
{
Expand Down
1 change: 1 addition & 0 deletions src/storage/hummock_sdk/src/change_log.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit 971207d

Please sign in to comment.