Skip to content

Commit

Permalink
Import WorkerId struct and add to crate::manager.
Browse files Browse the repository at this point in the history
  • Loading branch information
shanicky committed Nov 7, 2023
1 parent 5cf5bb6 commit e51ea92
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/meta/src/stream/scale_controller.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ use risingwave_common::bail;
use risingwave_common::buffer::Bitmap;
use risingwave_common::hash::{ActorMapping, ParallelUnitId};
use risingwave_common::util::iter_util::ZipEqDebug;
use risingwave_meta_model_v2::WorkerId;
use risingwave_pb::common::{ActorInfo, ParallelUnit, WorkerNode};
use risingwave_pb::meta::get_reschedule_plan_request::{Policy, StableResizePolicy};
use risingwave_pb::meta::table_fragments::actor_status::ActorState;
Expand All @@ -36,7 +35,7 @@ use risingwave_pb::stream_service::{
use uuid::Uuid;

use crate::barrier::Reschedule;
use crate::manager::{ClusterManagerRef, FragmentManagerRef, IdCategory, MetaSrvEnv};
use crate::manager::{ClusterManagerRef, FragmentManagerRef, IdCategory, MetaSrvEnv, WorkerId};
use crate::model::{ActorId, DispatcherId, FragmentId, TableFragments};
use crate::stream::{rebalance_actor_vnode, ParallelUnitReschedule, SourceManagerRef};
use crate::MetaResult;
Expand Down

0 comments on commit e51ea92

Please sign in to comment.