From e70bd7f7f0817c6272c98eeb7d1fdbb9f0a1bfe3 Mon Sep 17 00:00:00 2001 From: ohad bitton <32278684+ohadbitt@users.noreply.github.com> Date: Mon, 27 Jan 2025 12:39:55 +0200 Subject: [PATCH] Update KustoReader.scala Fix dist --- .../com/microsoft/kusto/spark/datasource/KustoReader.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala b/connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala index ad29994c..c16376fe 100644 --- a/connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala +++ b/connector/src/main/scala/com/microsoft/kusto/spark/datasource/KustoReader.scala @@ -242,7 +242,7 @@ private[kusto] object KustoReader { val now = Instant.now(Clock.systemUTC()) for (storage <- storageParameters.storageCredentials) { storage.authMethod match { - case AuthMethod.Sas => + case AuthMethod.Key => if (!KustoAzureFsSetupCache.updateAndGetPrevStorageAccountAccess( storage.storageAccountName, storage.storageAccountKey, @@ -251,7 +251,7 @@ private[kusto] object KustoReader { s"fs.azure.account.key.${storage.storageAccountName}.blob.${storageParameters.endpointSuffix}", s"${storage.storageAccountKey}") } - case AuthMethod.Key => + case AuthMethod.Sas => if (!KustoAzureFsSetupCache.updateAndGetPrevSas( storage.blobContainer, storage.storageAccountName,