Skip to content

Commit

Permalink
Merge branch 'main' of github.com:singularity-data/risingwave into yu…
Browse files Browse the repository at this point in the history
…hao/add-secret-ref-to-source
  • Loading branch information
yuhao-su committed Jun 17, 2024
2 parents 4865c83 + d555b5c commit d13ed73
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/meta/src/controller/fragment.rs
Original file line number Diff line number Diff line change
Expand Up @@ -864,7 +864,7 @@ impl CatalogController {
/// collected
pub async fn load_all_actors(&self) -> MetaResult<ActorInfos> {
let inner = self.inner.read().await;
let actor_info: Vec<(ActorId, WorkerId, FragmentId, i32, Vec<i32>)> = Actor::find()
let actor_info: Vec<(ActorId, WorkerId, FragmentId, i32, I32Array)> = Actor::find()
.select_only()
.column(actor::Column::ActorId)
.column(actor::Column::WorkerId)
Expand All @@ -880,6 +880,7 @@ impl CatalogController {
let mut fragment_infos = HashMap::new();

for (actor_id, worker_id, fragment_id, type_mask, state_table_ids) in actor_info {
let state_table_ids = state_table_ids.into_inner();
match fragment_infos.entry(fragment_id as crate::model::FragmentId) {
Entry::Occupied(mut entry) => {
let info: &mut InflightFragmentInfo = entry.get_mut();
Expand Down

0 comments on commit d13ed73

Please sign in to comment.