From 8de5c731df7efadfe7324f8fca7ef50ee95db1b7 Mon Sep 17 00:00:00 2001 From: Gio Gutierrez Date: Tue, 14 May 2024 10:48:20 -0500 Subject: [PATCH] fix: All clippy warnings --- src/common/src/array/arrow/arrow_udf.rs | 2 -- src/connector/src/parser/avro/parser.rs | 4 +--- src/connector/src/parser/debezium/avro_parser.rs | 4 +--- src/connector/src/source/kinesis/source/reader.rs | 1 - src/connector/src/source/nexmark/source/reader.rs | 2 +- src/meta/src/controller/catalog.rs | 1 - src/storage/hummock_test/src/test_utils.rs | 1 + src/storage/src/monitor/traced_store.rs | 1 - src/stream/src/common/compact_chunk.rs | 1 - src/stream/src/executor/chain.rs | 1 - src/stream/src/executor/dedup/append_only_dedup.rs | 6 +----- src/stream/src/executor/dispatch.rs | 11 +++-------- src/stream/src/executor/dml.rs | 6 +----- src/stream/src/executor/dynamic_filter.rs | 4 +--- src/stream/src/executor/filter.rs | 5 +---- src/stream/src/executor/hash_join.rs | 6 +----- src/stream/src/executor/hop_window.rs | 6 +----- src/stream/src/executor/integration_tests.rs | 8 ++------ src/stream/src/executor/join/hash_join.rs | 1 - src/stream/src/executor/lookup_union.rs | 4 +--- src/stream/src/executor/merge.rs | 7 +------ src/stream/src/executor/mview/materialize.rs | 10 ++-------- src/stream/src/executor/project.rs | 8 +++----- src/stream/src/executor/receiver.rs | 4 +--- src/stream/src/executor/row_id_gen.rs | 6 ++---- src/stream/src/executor/simple_agg.rs | 2 -- src/stream/src/executor/sink.rs | 1 - src/stream/src/executor/sort.rs | 5 +---- src/stream/src/executor/source/source_executor.rs | 7 +------ src/stream/src/executor/source/state_table_handler.rs | 6 ++---- src/stream/src/executor/stateless_simple_agg.rs | 3 --- src/stream/src/executor/top_n/group_top_n.rs | 5 +---- src/stream/src/executor/top_n/top_n_plain.rs | 4 ---- src/stream/src/executor/union.rs | 3 --- src/stream/src/executor/watermark_filter.rs | 5 +---- src/stream/src/executor/wrapper/epoch_check.rs | 2 +- src/stream/src/task/barrier_manager/tests.rs | 2 -- .../simulation/tests/integration_tests/scale/plan.rs | 1 - 38 files changed, 32 insertions(+), 124 deletions(-) diff --git a/src/common/src/array/arrow/arrow_udf.rs b/src/common/src/array/arrow/arrow_udf.rs index 5a44ef143961..17425d8449a5 100644 --- a/src/common/src/array/arrow/arrow_udf.rs +++ b/src/common/src/array/arrow/arrow_udf.rs @@ -124,11 +124,9 @@ impl FromArrow for UdfArrowConvert { #[cfg(test)] mod tests { - use std::sync::Arc; use super::*; use crate::array::*; - use crate::buffer::Bitmap; #[test] fn struct_array() { diff --git a/src/connector/src/parser/avro/parser.rs b/src/connector/src/parser/avro/parser.rs index 9ec35a02197b..c1950313b5e5 100644 --- a/src/connector/src/parser/avro/parser.rs +++ b/src/connector/src/parser/avro/parser.rs @@ -197,9 +197,7 @@ mod test { use crate::connector_common::AwsAuthProps; use crate::parser::plain_parser::PlainParser; use crate::parser::unified::avro::unix_epoch_days; - use crate::parser::{ - AccessBuilderImpl, EncodingType, SourceStreamChunkBuilder, SpecificParserConfig, - }; + use crate::parser::{AccessBuilderImpl, SourceStreamChunkBuilder, SpecificParserConfig}; use crate::source::{SourceColumnDesc, SourceContext}; fn test_data_path(file_name: &str) -> String { diff --git a/src/connector/src/parser/debezium/avro_parser.rs b/src/connector/src/parser/debezium/avro_parser.rs index f74e1289bf00..3b11a1926f10 100644 --- a/src/connector/src/parser/debezium/avro_parser.rs +++ b/src/connector/src/parser/debezium/avro_parser.rs @@ -150,9 +150,7 @@ mod tests { use risingwave_pb::plan_common::{PbEncodeType, PbFormatType}; use super::*; - use crate::parser::{ - DebeziumAvroParserConfig, DebeziumParser, SourceStreamChunkBuilder, SpecificParserConfig, - }; + use crate::parser::{DebeziumParser, SourceStreamChunkBuilder, SpecificParserConfig}; use crate::source::{SourceColumnDesc, SourceContext}; const DEBEZIUM_AVRO_DATA: &[u8] = b"\x00\x00\x00\x00\x06\x00\x02\xd2\x0f\x0a\x53\x61\x6c\x6c\x79\x0c\x54\x68\x6f\x6d\x61\x73\x2a\x73\x61\x6c\x6c\x79\x2e\x74\x68\x6f\x6d\x61\x73\x40\x61\x63\x6d\x65\x2e\x63\x6f\x6d\x16\x32\x2e\x31\x2e\x32\x2e\x46\x69\x6e\x61\x6c\x0a\x6d\x79\x73\x71\x6c\x12\x64\x62\x73\x65\x72\x76\x65\x72\x31\xc0\xb4\xe8\xb7\xc9\x61\x00\x30\x66\x69\x72\x73\x74\x5f\x69\x6e\x5f\x64\x61\x74\x61\x5f\x63\x6f\x6c\x6c\x65\x63\x74\x69\x6f\x6e\x12\x69\x6e\x76\x65\x6e\x74\x6f\x72\x79\x00\x02\x12\x63\x75\x73\x74\x6f\x6d\x65\x72\x73\x00\x00\x20\x6d\x79\x73\x71\x6c\x2d\x62\x69\x6e\x2e\x30\x30\x30\x30\x30\x33\x8c\x06\x00\x00\x00\x02\x72\x02\x92\xc3\xe8\xb7\xc9\x61\x00"; diff --git a/src/connector/src/source/kinesis/source/reader.rs b/src/connector/src/source/kinesis/source/reader.rs index 9a72998a341f..4504324c5fb9 100644 --- a/src/connector/src/source/kinesis/source/reader.rs +++ b/src/connector/src/source/kinesis/source/reader.rs @@ -305,7 +305,6 @@ mod tests { use super::*; use crate::connector_common::KinesisCommon; - use crate::source::kinesis::split::KinesisSplit; use crate::source::SourceContext; #[tokio::test] diff --git a/src/connector/src/source/nexmark/source/reader.rs b/src/connector/src/source/nexmark/source/reader.rs index 6441baa154ae..d1f10f4a00fc 100644 --- a/src/connector/src/source/nexmark/source/reader.rs +++ b/src/connector/src/source/nexmark/source/reader.rs @@ -210,7 +210,7 @@ impl NexmarkSplitReader { #[cfg(test)] mod tests { use super::*; - use crate::source::nexmark::{NexmarkProperties, NexmarkSplitEnumerator}; + use crate::source::nexmark::NexmarkSplitEnumerator; use crate::source::{SourceContext, SourceEnumeratorContext, SplitEnumerator}; #[tokio::test] diff --git a/src/meta/src/controller/catalog.rs b/src/meta/src/controller/catalog.rs index 409672138d79..f8ec470a7491 100644 --- a/src/meta/src/controller/catalog.rs +++ b/src/meta/src/controller/catalog.rs @@ -3008,7 +3008,6 @@ impl CatalogControllerInner { #[cfg(test)] #[cfg(not(madsim))] mod tests { - use risingwave_meta_model_v2::ViewId; use super::*; diff --git a/src/storage/hummock_test/src/test_utils.rs b/src/storage/hummock_test/src/test_utils.rs index 06a0d43ccac8..9a4e674e1f8a 100644 --- a/src/storage/hummock_test/src/test_utils.rs +++ b/src/storage/hummock_test/src/test_utils.rs @@ -117,6 +117,7 @@ impl TestIngestBatch for S { #[cfg(test)] #[async_trait::async_trait] pub(crate) trait HummockStateStoreTestTrait: StateStore { + #[allow(dead_code)] fn get_pinned_version(&self) -> PinnedVersion; async fn seal_and_sync_epoch(&self, epoch: u64) -> StorageResult { self.seal_epoch(epoch, true); diff --git a/src/storage/src/monitor/traced_store.rs b/src/storage/src/monitor/traced_store.rs index 47c0de67729b..df93f4c2d1a1 100644 --- a/src/storage/src/monitor/traced_store.rs +++ b/src/storage/src/monitor/traced_store.rs @@ -29,7 +29,6 @@ use crate::error::StorageResult; use crate::hummock::sstable_store::SstableStoreRef; use crate::hummock::{HummockStorage, SstableObjectIdManagerRef}; use crate::store::*; -use crate::StateStore; #[derive(Clone)] pub struct TracedStateStore { diff --git a/src/stream/src/common/compact_chunk.rs b/src/stream/src/common/compact_chunk.rs index dc5ae1561a2b..5d6acb512542 100644 --- a/src/stream/src/common/compact_chunk.rs +++ b/src/stream/src/common/compact_chunk.rs @@ -333,7 +333,6 @@ pub fn merge_chunk_row(stream_chunk: StreamChunk, pk_indices: &[usize]) -> Strea #[cfg(test)] mod tests { - use risingwave_common::array::StreamChunk; use risingwave_common::test_prelude::StreamChunkTestExt; use super::*; diff --git a/src/stream/src/executor/chain.rs b/src/stream/src/executor/chain.rs index ebcbe1e4e49b..96b9422a97b2 100644 --- a/src/stream/src/executor/chain.rs +++ b/src/stream/src/executor/chain.rs @@ -103,7 +103,6 @@ impl Execute for ChainExecutor { #[cfg(test)] mod test { - use std::default::Default; use futures::StreamExt; use risingwave_common::array::stream_chunk::StreamChunkTestExt; diff --git a/src/stream/src/executor/dedup/append_only_dedup.rs b/src/stream/src/executor/dedup/append_only_dedup.rs index f73e19681540..f98847cf1de4 100644 --- a/src/stream/src/executor/dedup/append_only_dedup.rs +++ b/src/stream/src/executor/dedup/append_only_dedup.rs @@ -182,19 +182,15 @@ impl Execute for AppendOnlyDedupExecutor { #[cfg(test)] mod tests { use std::sync::atomic::AtomicU64; - use std::sync::Arc; - use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, Schema, TableId}; + use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, TableId}; use risingwave_common::test_prelude::StreamChunkTestExt; - use risingwave_common::types::DataType; use risingwave_common::util::epoch::test_epoch; use risingwave_common::util::sort_util::OrderType; use risingwave_storage::memory::MemoryStateStore; use super::*; - use crate::common::table::state_table::StateTable; use crate::executor::test_utils::MockSource; - use crate::executor::ActorContext; #[tokio::test] async fn test_dedup_executor() { diff --git a/src/stream/src/executor/dispatch.rs b/src/stream/src/executor/dispatch.rs index 6c644466f968..9e6503c2d9a2 100644 --- a/src/stream/src/executor/dispatch.rs +++ b/src/stream/src/executor/dispatch.rs @@ -1029,26 +1029,21 @@ impl Dispatcher for SimpleDispatcher { #[cfg(test)] mod tests { use std::hash::{BuildHasher, Hasher}; - use std::sync::{Arc, Mutex}; + use std::sync::Mutex; use async_trait::async_trait; - use futures::{pin_mut, StreamExt}; - use itertools::Itertools; + use futures::pin_mut; use risingwave_common::array::stream_chunk::StreamChunkTestExt; - use risingwave_common::array::{Array, ArrayBuilder, I32ArrayBuilder, Op}; - use risingwave_common::catalog::Schema; + use risingwave_common::array::{Array, ArrayBuilder, I32ArrayBuilder}; use risingwave_common::config; - use risingwave_common::hash::VirtualNode; use risingwave_common::util::epoch::test_epoch; use risingwave_common::util::hash_util::Crc32FastBuilder; - use risingwave_common::util::iter_util::ZipEqFast; use risingwave_pb::stream_plan::DispatcherType; use super::*; use crate::executor::exchange::output::Output; use crate::executor::exchange::permit::channel_for_test; use crate::executor::receiver::ReceiverExecutor; - use crate::executor::Execute; use crate::task::test_utils::helper_make_local_actor; #[derive(Debug)] diff --git a/src/stream/src/executor/dml.rs b/src/stream/src/executor/dml.rs index b8839d76000c..adcb3f01ab8b 100644 --- a/src/stream/src/executor/dml.rs +++ b/src/stream/src/executor/dml.rs @@ -273,13 +273,9 @@ impl Execute for DmlExecutor { #[cfg(test)] mod tests { - use std::sync::Arc; - use risingwave_common::array::StreamChunk; - use risingwave_common::catalog::{ColumnId, Field, Schema, INITIAL_TABLE_VERSION_ID}; + use risingwave_common::catalog::{ColumnId, Field, INITIAL_TABLE_VERSION_ID}; use risingwave_common::test_prelude::StreamChunkTestExt; - use risingwave_common::transaction::transaction_id::TxnId; - use risingwave_common::types::DataType; use risingwave_common::util::epoch::test_epoch; use risingwave_dml::dml_manager::DmlManager; diff --git a/src/stream/src/executor/dynamic_filter.rs b/src/stream/src/executor/dynamic_filter.rs index eb2a0648225d..e9c631202e8b 100644 --- a/src/stream/src/executor/dynamic_filter.rs +++ b/src/stream/src/executor/dynamic_filter.rs @@ -488,9 +488,8 @@ impl Execute #[cfg(test)] mod tests { - use risingwave_common::array::stream_chunk::StreamChunkTestExt; use risingwave_common::array::*; - use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, Schema, TableId}; + use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, TableId}; use risingwave_common::util::epoch::test_epoch; use risingwave_common::util::sort_util::OrderType; use risingwave_hummock_sdk::HummockReadEpoch; @@ -499,7 +498,6 @@ mod tests { use super::*; use crate::executor::test_utils::{MessageSender, MockSource, StreamExecutorTestExt}; - use crate::executor::{ActorContext, StreamExecutorResult}; async fn create_in_memory_state_table( mem_state: MemoryStateStore, diff --git a/src/stream/src/executor/filter.rs b/src/stream/src/executor/filter.rs index 4d1ecb098bd8..b183719a9a67 100644 --- a/src/stream/src/executor/filter.rs +++ b/src/stream/src/executor/filter.rs @@ -157,11 +157,8 @@ impl FilterExecutor { #[cfg(test)] mod tests { - use futures::StreamExt; use risingwave_common::array::stream_chunk::StreamChunkTestExt; - use risingwave_common::array::StreamChunk; - use risingwave_common::catalog::{Field, Schema}; - use risingwave_common::types::DataType; + use risingwave_common::catalog::Field; use super::super::test_utils::expr::build_from_pretty; use super::super::test_utils::MockSource; diff --git a/src/stream/src/executor/hash_join.rs b/src/stream/src/executor/hash_join.rs index a06d490400cd..60e2e532eb1f 100644 --- a/src/stream/src/executor/hash_join.rs +++ b/src/stream/src/executor/hash_join.rs @@ -1051,20 +1051,16 @@ impl HashJoinExecutor SortExecutor { #[cfg(test)] mod tests { use risingwave_common::array::stream_chunk::StreamChunkTestExt; - use risingwave_common::array::StreamChunk; - use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, Schema, TableId}; - use risingwave_common::types::DataType; + use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, TableId}; use risingwave_common::util::epoch::test_epoch; use risingwave_common::util::sort_util::OrderType; use risingwave_storage::memory::MemoryStateStore; use super::*; use crate::executor::test_utils::{MessageSender, MockSource, StreamExecutorTestExt}; - use crate::executor::{ActorContext, BoxedMessageStream, Execute}; async fn create_executor( sort_column_index: usize, diff --git a/src/stream/src/executor/source/source_executor.rs b/src/stream/src/executor/source/source_executor.rs index a793596c8ff6..a53f48827454 100644 --- a/src/stream/src/executor/source/source_executor.rs +++ b/src/stream/src/executor/source/source_executor.rs @@ -766,15 +766,11 @@ impl WaitEpochWorker { #[cfg(test)] mod tests { use std::collections::HashSet; - use std::time::Duration; - use futures::StreamExt; use maplit::{convert_args, hashmap}; - use risingwave_common::array::StreamChunk; - use risingwave_common::catalog::{ColumnId, Field, Schema, TableId}; + use risingwave_common::catalog::{ColumnId, Field, TableId}; use risingwave_common::system_param::local_manager::LocalSystemParamsManager; use risingwave_common::test_prelude::StreamChunkTestExt; - use risingwave_common::types::DataType; use risingwave_common::util::epoch::test_epoch; use risingwave_connector::source::datagen::DatagenSplit; use risingwave_connector::source::reader::desc::test_utils::create_source_desc_builder; @@ -786,7 +782,6 @@ mod tests { use super::*; use crate::executor::source::{default_source_internal_table, SourceStateTableHandler}; - use crate::executor::ActorContext; const MOCK_SOURCE_NAME: &str = "mock_source"; diff --git a/src/stream/src/executor/source/state_table_handler.rs b/src/stream/src/executor/source/state_table_handler.rs index 7fc12000656c..1d14de9a493c 100644 --- a/src/stream/src/executor/source/state_table_handler.rs +++ b/src/stream/src/executor/source/state_table_handler.rs @@ -257,11 +257,9 @@ pub fn default_source_internal_table(id: u32) -> PbTable { #[cfg(test)] pub(crate) mod tests { - use std::sync::Arc; - use risingwave_common::row::OwnedRow; - use risingwave_common::types::{Datum, ScalarImpl}; - use risingwave_common::util::epoch::{test_epoch, EpochPair}; + use risingwave_common::types::Datum; + use risingwave_common::util::epoch::test_epoch; use risingwave_connector::source::kafka::KafkaSplit; use risingwave_storage::memory::MemoryStateStore; use serde_json::Value; diff --git a/src/stream/src/executor/stateless_simple_agg.rs b/src/stream/src/executor/stateless_simple_agg.rs index 1360f4166008..dd1f39580c36 100644 --- a/src/stream/src/executor/stateless_simple_agg.rs +++ b/src/stream/src/executor/stateless_simple_agg.rs @@ -125,16 +125,13 @@ impl StatelessSimpleAggExecutor { #[cfg(test)] mod tests { use assert_matches::assert_matches; - use futures::StreamExt; use risingwave_common::array::stream_chunk::StreamChunkTestExt; - use risingwave_common::array::StreamChunk; use risingwave_common::catalog::schema_test_utils; use risingwave_common::util::epoch::test_epoch; use super::*; use crate::executor::test_utils::agg_executor::generate_agg_schema; use crate::executor::test_utils::MockSource; - use crate::executor::{Execute, StatelessSimpleAggExecutor}; #[tokio::test] async fn test_no_chunk() { diff --git a/src/stream/src/executor/top_n/group_top_n.rs b/src/stream/src/executor/top_n/group_top_n.rs index 3a8a618e3c83..d6b2af690d83 100644 --- a/src/stream/src/executor/top_n/group_top_n.rs +++ b/src/stream/src/executor/top_n/group_top_n.rs @@ -267,11 +267,9 @@ mod tests { use std::sync::atomic::AtomicU64; use assert_matches::assert_matches; - use futures::StreamExt; use risingwave_common::array::stream_chunk::StreamChunkTestExt; - use risingwave_common::catalog::{Field, Schema}; + use risingwave_common::catalog::Field; use risingwave_common::hash::SerializedKey; - use risingwave_common::types::DataType; use risingwave_common::util::epoch::test_epoch; use risingwave_common::util::sort_util::OrderType; use risingwave_storage::memory::MemoryStateStore; @@ -279,7 +277,6 @@ mod tests { use super::*; use crate::executor::test_utils::top_n_executor::create_in_memory_state_table; use crate::executor::test_utils::MockSource; - use crate::executor::{ActorContext, Barrier, Execute, Message}; fn create_schema() -> Schema { Schema { diff --git a/src/stream/src/executor/top_n/top_n_plain.rs b/src/stream/src/executor/top_n/top_n_plain.rs index 30aee860a8fc..25227b5f556a 100644 --- a/src/stream/src/executor/top_n/top_n_plain.rs +++ b/src/stream/src/executor/top_n/top_n_plain.rs @@ -185,7 +185,6 @@ where #[cfg(test)] mod tests { use assert_matches::assert_matches; - use futures::StreamExt; use risingwave_common::array::stream_chunk::StreamChunkTestExt; use risingwave_common::catalog::{Field, Schema}; use risingwave_common::types::DataType; @@ -201,7 +200,6 @@ mod tests { use risingwave_common::util::epoch::test_epoch; use super::*; - use crate::executor::{ActorContext, Execute}; fn create_stream_chunks() -> Vec { let chunk1 = StreamChunk::from_pretty( " I I @@ -685,7 +683,6 @@ mod tests { use super::*; use crate::executor::test_utils::top_n_executor::create_in_memory_state_table_from_state_store; - use crate::executor::{ActorContext, Execute}; fn create_source_new() -> Executor { let mut chunks = vec![ @@ -1002,7 +999,6 @@ mod tests { use super::*; use crate::executor::test_utils::top_n_executor::create_in_memory_state_table_from_state_store; - use crate::executor::{ActorContext, Execute}; fn create_source() -> Executor { let mut chunks = vec![ diff --git a/src/stream/src/executor/union.rs b/src/stream/src/executor/union.rs index ac8f3581dda1..f72f5170ce86 100644 --- a/src/stream/src/executor/union.rs +++ b/src/stream/src/executor/union.rs @@ -145,12 +145,9 @@ async fn merge(inputs: Vec) { mod tests { use async_stream::try_stream; use risingwave_common::array::stream_chunk::StreamChunkTestExt; - use risingwave_common::array::StreamChunk; - use risingwave_common::types::{DataType, ScalarImpl}; use risingwave_common::util::epoch::test_epoch; use super::*; - use crate::executor::Watermark; #[tokio::test] async fn union() { diff --git a/src/stream/src/executor/watermark_filter.rs b/src/stream/src/executor/watermark_filter.rs index c966d0411acb..2aca1251dd05 100644 --- a/src/stream/src/executor/watermark_filter.rs +++ b/src/stream/src/executor/watermark_filter.rs @@ -349,8 +349,7 @@ impl WatermarkFilterExecutor { #[cfg(test)] mod tests { use itertools::Itertools; - use risingwave_common::array::StreamChunk; - use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, Schema, TableDesc}; + use risingwave_common::catalog::{ColumnDesc, ColumnId, Field, TableDesc}; use risingwave_common::test_prelude::StreamChunkTestExt; use risingwave_common::types::Date; use risingwave_common::util::epoch::test_epoch; @@ -359,12 +358,10 @@ mod tests { use risingwave_pb::common::ColumnOrder; use risingwave_pb::plan_common::PbColumnCatalog; use risingwave_storage::memory::MemoryStateStore; - use risingwave_storage::table::TableDistribution; use super::*; use crate::executor::test_utils::expr::build_from_pretty; use crate::executor::test_utils::{MessageSender, MockSource}; - use crate::executor::{ActorContext, ExecutorInfo}; const WATERMARK_TYPE: DataType = DataType::Timestamp; diff --git a/src/stream/src/executor/wrapper/epoch_check.rs b/src/stream/src/executor/wrapper/epoch_check.rs index 0110d8a0d86e..335c524700f0 100644 --- a/src/stream/src/executor/wrapper/epoch_check.rs +++ b/src/stream/src/executor/wrapper/epoch_check.rs @@ -75,7 +75,7 @@ pub async fn epoch_check(info: Arc, input: impl MessageStream) { #[cfg(test)] mod tests { use assert_matches::assert_matches; - use futures::{pin_mut, StreamExt}; + use futures::pin_mut; use risingwave_common::array::StreamChunk; use risingwave_common::util::epoch::test_epoch; diff --git a/src/stream/src/task/barrier_manager/tests.rs b/src/stream/src/task/barrier_manager/tests.rs index 99efb00269b8..5fbedcdfd0dc 100644 --- a/src/stream/src/task/barrier_manager/tests.rs +++ b/src/stream/src/task/barrier_manager/tests.rs @@ -20,10 +20,8 @@ use std::task::Poll; use assert_matches::assert_matches; use futures::future::join_all; use futures::FutureExt; -use itertools::Itertools; use risingwave_common::util::epoch::test_epoch; use risingwave_pb::stream_service::{streaming_control_stream_request, InjectBarrierRequest}; -use tokio::sync::mpsc::unbounded_channel; use tokio_stream::wrappers::UnboundedReceiverStream; use super::*; diff --git a/src/tests/simulation/tests/integration_tests/scale/plan.rs b/src/tests/simulation/tests/integration_tests/scale/plan.rs index e1d8148632c6..d39e159fc61d 100644 --- a/src/tests/simulation/tests/integration_tests/scale/plan.rs +++ b/src/tests/simulation/tests/integration_tests/scale/plan.rs @@ -13,7 +13,6 @@ // limitations under the License. use std::collections::HashMap; -use std::default::Default; use anyhow::Result; use itertools::Itertools;