From d305cbd811d64ee46f46b6319c23964ba5571b82 Mon Sep 17 00:00:00 2001 From: Shanicky Chen Date: Wed, 27 Sep 2023 18:06:07 +0800 Subject: [PATCH] Removed unnecessary imports and reordered imports in source_manager.rs --- src/meta/src/rpc/election/etcd.rs | 2 -- src/meta/src/stream/source_manager.rs | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/src/meta/src/rpc/election/etcd.rs b/src/meta/src/rpc/election/etcd.rs index ecf7727100458..7a639761c8ba6 100644 --- a/src/meta/src/rpc/election/etcd.rs +++ b/src/meta/src/rpc/election/etcd.rs @@ -21,8 +21,6 @@ use anyhow::anyhow; use etcd_client::{ConnectOptions, Error, GetOptions, LeaderKey, ResignOptions}; use risingwave_common::bail; use risingwave_common::util::runtime::BackgroundShutdownRuntime; -use serde::Serialize; -use tokio::runtime::Runtime; use tokio::sync::watch::Receiver; use tokio::sync::{oneshot, watch}; use tokio::time; diff --git a/src/meta/src/stream/source_manager.rs b/src/meta/src/stream/source_manager.rs index 871228f31dce0..4608027232a24 100644 --- a/src/meta/src/stream/source_manager.rs +++ b/src/meta/src/stream/source_manager.rs @@ -23,8 +23,8 @@ use std::time::Duration; use anyhow::anyhow; use itertools::Itertools; use risingwave_common::catalog::TableId; -use risingwave_connector::dispatch_source_prop; use risingwave_common::util::runtime::BackgroundShutdownRuntime; +use risingwave_connector::dispatch_source_prop; use risingwave_connector::source::{ ConnectorProperties, SourceEnumeratorContext, SourceEnumeratorInfo, SourceProperties, SplitEnumerator, SplitId, SplitImpl, SplitMetaData,