Skip to content

Commit

Permalink
chore: remove some debug log
Browse files Browse the repository at this point in the history
  • Loading branch information
paomian committed Jun 13, 2024
1 parent 6aed131 commit db827df
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions src/pipeline/src/manager/table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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};
Expand Down Expand Up @@ -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())
{
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -424,7 +423,7 @@ impl PipelineTable {
),
})?;

info!(
debug!(
"find_pipeline_by_name: pipeline_content: {:?}, pipeline_created_at: {:?}",
pipeline_content, pipeline_created_at
);
Expand Down

0 comments on commit db827df

Please sign in to comment.