fix clippy and remove one misuse

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jan 9, 2024 · 6ddfd11 · 6ddfd11
1 parent 7a0be5b
commit 6ddfd11
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/src/connector/src/parser/mod.rs b/src/connector/src/parser/mod.rs
@@ -528,7 +528,7 @@ impl<P: ByteStreamSourceParser> P {
     /// A [`SourceWithStateStream`] which is a stream of parsed messages.
     pub fn into_stream(self, data_stream: BoxSourceStream) -> impl SourceWithStateStream {
         // Enable tracing to provide more information for parsing failures.
-        let source_info = self.source_ctx().source_info.clone();
+        let source_info = self.source_ctx().source_info;
 
         // The parser stream will be long-lived. We use `instrument_with` here to create
         // a new span for the polling of each chunk.

diff --git a/src/meta/node/src/server.rs b/src/meta/node/src/server.rs
@@ -264,7 +264,6 @@ pub fn rpc_serve_with_store(
 
                 let election_client_ = election_client.clone();
                 Some(tokio::spawn(async move {
-                    let _ = tracing::span!(tracing::Level::INFO, "follower services").enter();
                     start_service_as_election_follower(
                         svc_shutdown_rx_clone,
                         follower_shutdown_rx,