fmt

risingwavelabs · Feb 1, 2024 · 8f0681b · 8f0681b
1 parent 11fdfcd
commit 8f0681b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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)