Reduce info logs

crates/arroyo-connectors/src/filesystem/sink/mod.rs

@@ -37,7 +37,7 @@ use futures::{stream::FuturesUnordered, Future};
 use futures::{stream::StreamExt, TryStreamExt};
 use object_store::{multipart::PartId, path::Path, MultipartId};
 use tokio::sync::mpsc::{Receiver, Sender};
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 use uuid::Uuid;
 
 use arroyo_types::*;
@@ -507,7 +507,7 @@ async fn from_checkpoint(
             parts_to_add,
             trailing_bytes,
         } => {
-            info!("finishing file for path {:?}", path);
+            debug!("finishing file for path {:?}", path);
             let multipart_id = object_store
                 .start_multipart(path)
                 .await
@@ -527,7 +527,7 @@ async fn from_checkpoint(
                     .await?;
                 parts.push(upload_part);
             }
-            info!(
+            debug!(
                 "parts: {:?}, pushed_size: {:?}, multipart id: {:?}",
                 parts, pushed_size, multipart_id
             );

crates/arroyo-state/src/tables/global_keyed_map.rs

@@ -17,7 +17,7 @@ use parquet::{
     basic::ZstdLevel,
     file::properties::{EnabledStatistics, WriterProperties},
 };
-use tracing::info;
+use tracing::debug;
 
 use std::iter::Zip;
 
@@ -244,7 +244,7 @@ impl TableEpochCheckpointer for GlobalKeyedCheckpointer {
                 bail!("global keyed data expects KeyedData, not record batches")
             }
             TableData::CommitData { data } => {
-                info!("received commit data");
+                debug!("received commit data");
                 // set commit data, failing if it was already set
                 if self.commit_data.is_some() {
                     bail!("commit data already set for this epoch")