chore: Remove println

risingwavelabs · Mar 5, 2024 · b38d5fd · b38d5fd
1 parent f862c7f
commit b38d5fd
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/src/connector/src/sink/mqtt.rs b/src/connector/src/sink/mqtt.rs
@@ -178,7 +178,6 @@ impl MqttSinkWriter {
 
         let stopped = Arc::new(AtomicBool::new(false));
         let stopped_clone = stopped.clone();
-
         tokio::spawn(async move {
             while !stopped_clone.load(std::sync::atomic::Ordering::Relaxed) {
                 match eventloop.poll().await {
@@ -195,7 +194,6 @@ impl MqttSinkWriter {
                             continue;
                         }
                         err => {
-                            println!("Err: {:?}", err);
                             tracing::error!("Failed to poll mqtt eventloop: {}", err.as_report());
                             std::thread::sleep(std::time::Duration::from_secs(1));
                         }

diff --git a/src/connector/src/source/mqtt/source/reader.rs b/src/connector/src/source/mqtt/source/reader.rs
@@ -49,9 +49,10 @@ impl SplitReader for MqttSplitReader {
         source_ctx: SourceContextRef,
         _columns: Option<Vec<Column>>,
     ) -> Result<Self> {
-        let (client, eventloop) = properties
-            .common
-            .build_client(source_ctx.source_info.actor_id, source_ctx.source_info.fragment_id)?;
+        let (client, eventloop) = properties.common.build_client(
+            source_ctx.source_info.actor_id,
+            source_ctx.source_info.fragment_id,
+        )?;
 
         let qos = properties.common.qos();