chore(meta): adjust the log level of some semaphore from info to debug (#18367)

* chore(meta): remove useless code for semaphore

* chore(meta): remove useless code for semaphore

* chore(meta): adjust the log level of some semaphore from info to debug

* chore(meta): adjust the log level of some semaphore from info to debug

Author: zhang2014

src/meta/semaphore/src/acquirer/acquirer.rs

@@ -397,7 +397,7 @@ impl Acquirer {
                     // Extend the lease only if the entry still exists. If the entry has been removed,
                     // it means the semaphore has been released. Re-inserting it would cause confusion
                     // in the semaphore state and potentially lead to inconsistent behavior.
-                    info!(
+                    log::debug!(
                         "{}: About to extend semaphore permit lease: {} ttl: {:?}",
                         ctx, key_str, ttl
                     );

src/meta/semaphore/src/meta_event_subscriber/processor.rs

@@ -15,7 +15,6 @@
 use codeq::Decode;
 use databend_common_meta_types::protobuf::WatchResponse;
 use databend_common_meta_types::SeqV;
-use log::info;
 use log::warn;
 use tokio::sync::mpsc;
 
@@ -75,11 +74,13 @@ impl Processor {
         prev: Option<SeqV<PermitEntry>>,
         current: Option<SeqV<PermitEntry>>,
     ) -> Result<(), ConnectionClosed> {
-        info!(
+        log::debug!(
             "{} processing kv change: {}: {:?} -> {:?}",
-            self.ctx, sem_key, prev, current
+            self.ctx,
+            sem_key,
+            prev,
+            current
         );
-
         // Update local queue to update the acquired/released state.
         let state_changes = match (prev, current) {
             (None, Some(entry)) => self.queue.insert(sem_key.seq, entry.data),
@@ -95,10 +96,10 @@ impl Processor {
             }
         };
 
-        info!("{} queue state: {}", self.ctx, self.queue);
+        log::debug!("{} queue state: {}", self.ctx, self.queue);
 
         for event in state_changes {
-            info!("{} sending event: {}", self.ctx, event);
+            log::debug!("{} sending event: {}", self.ctx, event);
 
             self.tx.send(event).await.map_err(|e| {
                 ConnectionClosed::new_str(format!("Semaphore-Watcher fail to send {}", e.0))

src/meta/semaphore/src/meta_event_subscriber/subscriber.rs

@@ -124,7 +124,7 @@ impl MetaEventSubscriber {
 
             match &watch_result {
                 Ok(t) => {
-                    info!(
+                    log::debug!(
                         "{} received event from watch-stream: Ok({})",
                         self.ctx,
                         t.display()