Fix

Author: krinart

system-adapters/databricks/src/main.rs

@@ -1007,11 +1007,11 @@ impl DatabricksAdapter {
             self.config.endpoint
         );
 
-        let mut total_read_bytes: u64 = 0;
-        let mut total_read_remote_bytes: u64 = 0;
-        let mut total_read_cache_bytes: u64 = 0;
-        let mut total_write_remote_bytes: u64 = 0;
-        let mut total_spill_to_disk_bytes: u64 = 0;
+        let mut _total_read_bytes: u64 = 0;
+        let mut _total_read_remote_bytes: u64 = 0;
+        let mut _total_read_cache_bytes: u64 = 0;
+        let mut _total_write_remote_bytes: u64 = 0;
+        let mut _total_spill_to_disk_bytes: u64 = 0;
         let mut page_token: Option<String> = None;
 
         loop {
@@ -1049,11 +1049,11 @@ impl DatabricksAdapter {
 
             for entry in &body.res {
                 if let Some(ref m) = entry.metrics {
-                    total_read_bytes += m.read_bytes.unwrap_or(0);
-                    total_read_remote_bytes += m.read_remote_bytes.unwrap_or(0);
-                    total_read_cache_bytes += m.read_cache_bytes.unwrap_or(0);
-                    total_write_remote_bytes += m.write_remote_bytes.unwrap_or(0);
-                    total_spill_to_disk_bytes += m.spill_to_disk_bytes.unwrap_or(0);
+                    _total_read_bytes += m.read_bytes.unwrap_or(0);
+                    _total_read_remote_bytes += m.read_remote_bytes.unwrap_or(0);
+                    _total_read_cache_bytes += m.read_cache_bytes.unwrap_or(0);
+                    _total_write_remote_bytes += m.write_remote_bytes.unwrap_or(0);
+                    _total_spill_to_disk_bytes += m.spill_to_disk_bytes.unwrap_or(0);
                 }
             }
 
@@ -1064,15 +1064,15 @@ impl DatabricksAdapter {
             }
         }
 
-        let total_write_bytes = total_write_remote_bytes + total_spill_to_disk_bytes;
+        let total_write_bytes = _total_write_remote_bytes + _total_spill_to_disk_bytes;
 
         // eprintln!(
         //     "[databricks-adapter] query history I/O breakdown: \
         //      total_read_bytes={total_read_bytes} (total_read_remote_bytes={total_read_remote_bytes}, total_read_cache_bytes={total_read_cache_bytes}), \
         //      total_write_bytes={total_write_bytes} (total_write_remote_bytes={total_write_remote_bytes}, total_spill_to_disk_bytes={total_spill_to_disk_bytes})"
         // );
 
-        Ok((total_read_bytes, total_write_bytes))
+        Ok((_total_read_bytes, total_write_bytes))
     }
 
     async fn ensure_cluster_ready(&self) -> Result<(String, bool)> {