diff --git a/parquet_file/src/storage.rs b/parquet_file/src/storage.rs index c4702fc246..963bab4618 100644 --- a/parquet_file/src/storage.rs +++ b/parquet_file/src/storage.rs @@ -242,9 +242,18 @@ impl ParquetStorage { // This is abort-able by the user by dropping the upload() future. // // Cloning `data` is a ref count inc, rather than a data copy. + let mut retried = false; while let Err(e) = self.object_store.put(&path, data.clone()).await { - error!(error=%e, ?meta, "failed to upload parquet file to object storage"); + warn!(error=%e, ?meta, "failed to upload parquet file to object storage, retrying"); tokio::time::sleep(Duration::from_secs(1)).await; + retried = true; + } + + if retried { + info!( + ?meta, + "Succeeded uploading files to object storage on retry" + ); } Ok((parquet_meta, file_size))