From db827df6cac53779139fcb9eb5e5d395321c63ad Mon Sep 17 00:00:00 2001
From: paomian <xpaomian@gmail.com>
Date: Thu, 13 Jun 2024 14:23:20 +0800
Subject: [PATCH] chore: remove some debug log

---
 src/pipeline/src/manager/table.rs | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/pipeline/src/manager/table.rs b/src/pipeline/src/manager/table.rs
index cc24c449dc1e..04ce982643f0 100644
--- a/src/pipeline/src/manager/table.rs
+++ b/src/pipeline/src/manager/table.rs
@@ -22,7 +22,7 @@ use api::v1::{
 };
 use common_query::OutputData;
 use common_recordbatch::util as record_util;
-use common_telemetry::info;
+use common_telemetry::{debug, info};
 use common_time::timestamp::{TimeUnit, Timestamp};
 use datafusion::datasource::DefaultTableSource;
 use datafusion::logical_expr::{and, col, lit};
@@ -273,7 +273,6 @@ impl PipelineTable {
         name: &str,
         version: Option<String>,
     ) -> Result<Pipeline<GreptimeTransformer>> {
-        info!("pipeline version: {:?}", version);
         if let Some(pipeline) =
             self.get_compiled_pipeline_from_cache(schema, name, version.as_deref())
         {
@@ -369,7 +368,7 @@ impl PipelineTable {
             .build()
             .context(BuildDfLogicalPlanSnafu)?;
 
-        info!("find_pipeline_by_name: plan: {:?}", plan);
+        debug!("find_pipeline_by_name: plan: {:?}", plan);
 
         let output = self
             .query_engine
@@ -424,7 +423,7 @@ impl PipelineTable {
                 ),
             })?;
 
-        info!(
+        debug!(
             "find_pipeline_by_name: pipeline_content: {:?}, pipeline_created_at: {:?}",
             pipeline_content, pipeline_created_at
         );