From 5182843bf0f47c61f84b9803cc46763d7d8b7201 Mon Sep 17 00:00:00 2001 From: Mihai Catalin Bleont Date: Wed, 28 Jan 2026 15:51:00 +0200 Subject: [PATCH] fixup! [HSTACK] - propagate creds for object store in distributed exec --- .../src/delta_datafusion/table_provider.rs | 23 ------------------- 1 file changed, 23 deletions(-) diff --git a/crates/core/src/delta_datafusion/table_provider.rs b/crates/core/src/delta_datafusion/table_provider.rs index 7046ea9ec3..ee94f8f772 100644 --- a/crates/core/src/delta_datafusion/table_provider.rs +++ b/crates/core/src/delta_datafusion/table_provider.rs @@ -1048,29 +1048,6 @@ impl ExecutionPlan for DeltaScan { partition: usize, context: Arc, ) -> Result { - let source_uri = Url::parse(self.table_uri.as_str()) - .map_err(|e| DataFusionError::External(Box::new(e)))?; - let url_key = object_store_url(&source_uri); - let runtime = context.runtime_env(); - // self.config - if runtime.object_store(url_key).is_err() { - let storage_config = StorageConfig::parse_options( - self.config.options.clone() - )?; - let source_store = logstore_for(source_uri,storage_config) - .map_err(|e| DataFusionError::External(Box::new(e)))?; - let object_store_url = source_store.object_store_url(); - - // check if delta store is already registered - if runtime.object_store(object_store_url.clone()).is_err() { - runtime.register_object_store( - object_store_url.as_ref(), - source_store.object_store(None), - ); - } - } - // Now that everything is set up, execute the inner Delta - self.parquet_scan.execute(partition, context) }