diff --git a/src/batch/src/executor/iceberg_scan.rs b/src/batch/src/executor/iceberg_scan.rs
index 3c69570049322..a417192d8124e 100644
--- a/src/batch/src/executor/iceberg_scan.rs
+++ b/src/batch/src/executor/iceberg_scan.rs
@@ -104,7 +104,8 @@ impl Executor for IcebergScanExecutor {
 impl IcebergScanExecutor {
     #[try_stream(ok = DataChunk, error = BatchError)]
     async fn do_execute(self: Box<Self>) {
-        let table = self.iceberg_config
+        let table = self
+            .iceberg_config
             .load_table()
             .await
             .map_err(BatchError::Internal)?;
diff --git a/src/connector/src/sink/iceberg/mod.rs b/src/connector/src/sink/iceberg/mod.rs
index 2783b15b4ddb5..0e4f28f64639c 100644
--- a/src/connector/src/sink/iceberg/mod.rs
+++ b/src/connector/src/sink/iceberg/mod.rs
@@ -392,7 +392,7 @@ impl IcebergConfig {
                 .into_iter()
                 .chain(self.table_name.split('.')),
         )
-            .map_err(|e| anyhow!("Unable to parse table name: {e}"))?;
+        .map_err(|e| anyhow!("Unable to parse table name: {e}"))?;
 
         catalog
             .load_table(&table_id)