From f9ffb43f8cdc297ad87be14df9457420b11fa8cb Mon Sep 17 00:00:00 2001
From: Raminder Singh <romi_ssk@yahoo.co.in>
Date: Sat, 30 Nov 2024 13:01:12 +0530
Subject: [PATCH] Revert "add logging to help troubleshoot"

This reverts commit 0cf109e0a3f6a1112f8152f290d30389087f1b8a.
---
 pg_replicate/src/conversions/table_row.rs           | 4 +---
 pg_replicate/src/pipeline/batching/data_pipeline.rs | 2 --
 2 files changed, 1 insertion(+), 5 deletions(-)

diff --git a/pg_replicate/src/conversions/table_row.rs b/pg_replicate/src/conversions/table_row.rs
index 71136de..5d984ed 100644
--- a/pg_replicate/src/conversions/table_row.rs
+++ b/pg_replicate/src/conversions/table_row.rs
@@ -3,7 +3,7 @@ use std::str::Utf8Error;
 
 use thiserror::Error;
 use tokio_postgres::types::Type;
-use tracing::{error, info};
+use tracing::error;
 
 use crate::{conversions::text::TextFormatConverter, pipeline::batching::BatchBoundary};
 
@@ -48,7 +48,6 @@ impl TableRowConverter {
         let mut values = Vec::with_capacity(column_schemas.len());
 
         let row_str = str::from_utf8(row)?;
-        info!("row_str: {row_str}");
         let mut column_schemas_iter = column_schemas.iter();
         let mut chars = row_str.chars();
         let mut val_str = String::with_capacity(10);
@@ -94,7 +93,6 @@ impl TableRowConverter {
                     return Err(TableRowConversionError::NumColsMismatch);
                 };
 
-                info!("val_str: {val_str:#?}");
                 let value = if val_str == "\\N" {
                     Cell::Null
                 } else {
diff --git a/pg_replicate/src/pipeline/batching/data_pipeline.rs b/pg_replicate/src/pipeline/batching/data_pipeline.rs
index 117de2a..6f9df24 100644
--- a/pg_replicate/src/pipeline/batching/data_pipeline.rs
+++ b/pg_replicate/src/pipeline/batching/data_pipeline.rs
@@ -60,8 +60,6 @@ impl<Src: Source, Snk: BatchSink> BatchDataPipeline<Src, Snk> {
                 continue;
             }
 
-            info!("table schema: {table_schema:#?}");
-
             self.sink.truncate_table(table_schema.table_id).await?;
 
             let table_rows = self