From 7f43881d4baa9c889fcaf79599ac29502d6a007b Mon Sep 17 00:00:00 2001 From: notauserx <82922717+notauserx@users.noreply.github.com> Date: Mon, 18 Nov 2024 22:16:02 +0600 Subject: [PATCH 1/2] fix auth value --- core/src/services/webhdfs/backend.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/services/webhdfs/backend.rs b/core/src/services/webhdfs/backend.rs index 4149a6986a29..64cdf8f1de04 100644 --- a/core/src/services/webhdfs/backend.rs +++ b/core/src/services/webhdfs/backend.rs @@ -174,7 +174,7 @@ impl Builder for WebhdfsBuilder { let auth = self .config .delegation - .map(|dt| format!("delegation_token={dt}")); + .map(|dt| format!("delegation={dt}")); let client = HttpClient::new()?; From 6eb26c435064ff4c5a51b0556c5c6e408a8fdd73 Mon Sep 17 00:00:00 2001 From: notauserx <82922717+notauserx@users.noreply.github.com> Date: Tue, 19 Nov 2024 10:20:44 +0600 Subject: [PATCH 2/2] fix format --- core/src/services/webhdfs/backend.rs | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/core/src/services/webhdfs/backend.rs b/core/src/services/webhdfs/backend.rs index 64cdf8f1de04..661e52c8b24f 100644 --- a/core/src/services/webhdfs/backend.rs +++ b/core/src/services/webhdfs/backend.rs @@ -171,10 +171,7 @@ impl Builder for WebhdfsBuilder { let atomic_write_dir = self.config.atomic_write_dir; - let auth = self - .config - .delegation - .map(|dt| format!("delegation={dt}")); + let auth = self.config.delegation.map(|dt| format!("delegation={dt}")); let client = HttpClient::new()?;