From 26297e583a44d59db8d2ed720e8420073b8dcb24 Mon Sep 17 00:00:00 2001 From: Eric Fu Date: Thu, 1 Feb 2024 15:29:07 +0800 Subject: [PATCH] chore: fix clippy (#14916) --- .../src/source/filesystem/opendal_source/opendal_reader.rs | 3 +-- src/connector/src/source/filesystem/s3/source/reader.rs | 4 +--- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/src/connector/src/source/filesystem/opendal_source/opendal_reader.rs b/src/connector/src/source/filesystem/opendal_source/opendal_reader.rs index d962f6e53e93a..49c6be470d573 100644 --- a/src/connector/src/source/filesystem/opendal_source/opendal_reader.rs +++ b/src/connector/src/source/filesystem/opendal_source/opendal_reader.rs @@ -19,7 +19,6 @@ use futures_async_stream::try_stream; use opendal::Operator; use risingwave_common::array::StreamChunk; use risingwave_common::error::RwError; -use risingwave_pb::meta::table_fragments::fragment; use tokio::io::BufReader; use tokio_util::io::{ReaderStream, StreamReader}; @@ -29,7 +28,7 @@ use crate::parser::{ByteStreamSourceParserImpl, ParserConfig}; use crate::source::filesystem::nd_streaming::need_nd_streaming; use crate::source::filesystem::{nd_streaming, OpendalFsSplit}; use crate::source::{ - self, BoxChunkSourceStream, Column, SourceContextRef, SourceMessage, SourceMeta, SplitMetaData, + BoxChunkSourceStream, Column, SourceContextRef, SourceMessage, SourceMeta, SplitMetaData, SplitReader, }; diff --git a/src/connector/src/source/filesystem/s3/source/reader.rs b/src/connector/src/source/filesystem/s3/source/reader.rs index f992b8381653d..d1e03b91fc6b9 100644 --- a/src/connector/src/source/filesystem/s3/source/reader.rs +++ b/src/connector/src/source/filesystem/s3/source/reader.rs @@ -39,9 +39,7 @@ use crate::source::filesystem::file_common::FsSplit; use crate::source::filesystem::nd_streaming; use crate::source::filesystem::nd_streaming::need_nd_streaming; use crate::source::filesystem::s3::S3Properties; -use crate::source::{ - self, BoxChunkSourceStream, Column, SourceContextRef, SourceMessage, SourceMeta, -}; +use crate::source::{BoxChunkSourceStream, Column, SourceContextRef, SourceMessage, SourceMeta}; const MAX_CHANNEL_BUFFER_SIZE: usize = 2048; const STREAM_READER_CAPACITY: usize = 4096;