From c3ae294edbf793878f59e1e4c7c4cbe675d971e3 Mon Sep 17 00:00:00 2001 From: Shanicky Chen Date: Mon, 8 Jul 2024 14:34:21 +0800 Subject: [PATCH] Cleanup imports and update Bitmap path in 4 Rust files --- src/meta/src/controller/streaming_job.rs | 1 - src/meta/src/controller/utils.rs | 2 +- src/meta/src/rpc/ddl_controller.rs | 2 +- src/meta/src/stream/stream_graph/schedule.rs | 2 +- 4 files changed, 3 insertions(+), 4 deletions(-) diff --git a/src/meta/src/controller/streaming_job.rs b/src/meta/src/controller/streaming_job.rs index adcd96415fe81..d3cfe899d4e57 100644 --- a/src/meta/src/controller/streaming_job.rs +++ b/src/meta/src/controller/streaming_job.rs @@ -17,7 +17,6 @@ use std::num::NonZeroUsize; use itertools::Itertools; use risingwave_common::bitmap::Bitmap; -use risingwave_common::hash::{ActorMapping, ParallelUnitId, ParallelUnitMapping}; use risingwave_common::util::column_index_mapping::ColIndexMapping; use risingwave_common::util::stream_graph_visitor::visit_stream_node; use risingwave_common::{bail, current_cluster_version}; diff --git a/src/meta/src/controller/utils.rs b/src/meta/src/controller/utils.rs index 1cf56c7c4152f..e27599e1a7bba 100644 --- a/src/meta/src/controller/utils.rs +++ b/src/meta/src/controller/utils.rs @@ -16,7 +16,7 @@ use std::collections::{BTreeSet, HashMap, HashSet}; use anyhow::anyhow; use itertools::Itertools; -use risingwave_common::buffer::Bitmap; +use risingwave_common::bitmap::Bitmap; use risingwave_common::hash; use risingwave_common::hash::{ActorMapping, WorkerSlotId, WorkerSlotMapping}; use risingwave_meta_model_migration::WithQuery; diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs index 1d1d454b7824a..28072cfc84637 100644 --- a/src/meta/src/rpc/ddl_controller.rs +++ b/src/meta/src/rpc/ddl_controller.rs @@ -24,7 +24,7 @@ use aes_siv::{Aes128SivAead, KeyInit}; use anyhow::Context; use itertools::Itertools; use rand::{Rng, RngCore}; -use risingwave_common::buffer::Bitmap; +use risingwave_common::bitmap::Bitmap; use risingwave_common::config::DefaultParallelism; use risingwave_common::hash::{ActorId, ActorMapping, VirtualNode}; use risingwave_common::system_param::reader::SystemParamsRead; diff --git a/src/meta/src/stream/stream_graph/schedule.rs b/src/meta/src/stream/stream_graph/schedule.rs index bde92ef2ce078..58d9af5d67181 100644 --- a/src/meta/src/stream/stream_graph/schedule.rs +++ b/src/meta/src/stream/stream_graph/schedule.rs @@ -24,7 +24,7 @@ use std::num::NonZeroUsize; use either::Either; use enum_as_inner::EnumAsInner; use itertools::Itertools; -use risingwave_common::buffer::Bitmap; +use risingwave_common::bitmap::Bitmap; use risingwave_common::hash::{ActorMapping, WorkerSlotId, WorkerSlotMapping}; use risingwave_common::{bail, hash}; use risingwave_pb::common::{ActorInfo, WorkerNode};