(nifi) branch main updated: NIFI-14865 Fixed Config Verification for List Azure Processors

[pvillard]

This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new bb27bebaff NIFI-14865 Fixed Config Verification for List Azure 
Processors
bb27bebaff is described below

commit bb27bebaffc01083b9ba7770595d2c92fd977e21
Author: exceptionfactory <exceptionfact...@apache.org>
AuthorDate: Fri Aug 15 11:59:37 2025 -0500

    NIFI-14865 Fixed Config Verification for List Azure Processors
    
    - Checked Listing Mode and created new Client Factory for configuration 
verification
    
    Signed-off-by: Pierre Villard <pierre.villard...@gmail.com>
    
    This closes #10209.
---
 .../processors/azure/storage/ListAzureBlobStorage_v12.java     |  9 ++++++++-
 .../processors/azure/storage/ListAzureDataLakeStorage.java     | 10 +++++++++-
 2 files changed, 17 insertions(+), 2 deletions(-)

diff --git 
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
 
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
index 1caafc94aa..ab9b63605c 100644
--- 
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
+++ 
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage_v12.java
@@ -210,6 +210,13 @@ public class ListAzureBlobStorage_v12 extends 
AbstractListAzureProcessor<BlobInf
 
     @Override
     protected List<BlobInfo> performListing(final ProcessContext context, 
final Long minTimestamp, final ListingMode listingMode) throws IOException {
+        final BlobServiceClientFactory currentClientFactory;
+        if (ListingMode.CONFIGURATION_VERIFICATION == listingMode) {
+            currentClientFactory = new BlobServiceClientFactory(getLogger(), 
getProxyOptions(context));
+        } else {
+            currentClientFactory = clientFactory;
+        }
+
         final String containerName = 
context.getProperty(CONTAINER).evaluateAttributeExpressions().getValue();
         final String prefix = 
context.getProperty(BLOB_NAME_PREFIX).evaluateAttributeExpressions().getValue();
         final long minimumTimestamp = minTimestamp == null ? 0 : minTimestamp;
@@ -219,7 +226,7 @@ public class ListAzureBlobStorage_v12 extends 
AbstractListAzureProcessor<BlobInf
 
             final AzureStorageCredentialsService_v12 credentialsService = 
context.getProperty(BLOB_STORAGE_CREDENTIALS_SERVICE).asControllerService(AzureStorageCredentialsService_v12.class);
             final AzureStorageCredentialsDetails_v12 credentialsDetails = 
credentialsService.getCredentialsDetails(Collections.emptyMap());
-            final BlobServiceClient storageClient = 
clientFactory.getStorageClient(credentialsDetails);
+            final BlobServiceClient storageClient = 
currentClientFactory.getStorageClient(credentialsDetails);
 
             final BlobContainerClient containerClient = 
storageClient.getBlobContainerClient(containerName);
 
diff --git 
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureDataLakeStorage.java
 
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureDataLakeStorage.java
index 11683e014c..825dfaea30 100644
--- 
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureDataLakeStorage.java
+++ 
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureDataLakeStorage.java
@@ -82,6 +82,7 @@ import static 
org.apache.nifi.processors.azure.storage.utils.AzureStorageUtils.D
 import static 
org.apache.nifi.processors.azure.storage.utils.AzureStorageUtils.FILESYSTEM;
 import static 
org.apache.nifi.processors.azure.storage.utils.AzureStorageUtils.evaluateDirectoryProperty;
 import static 
org.apache.nifi.processors.azure.storage.utils.AzureStorageUtils.evaluateFileSystemProperty;
+import static 
org.apache.nifi.processors.azure.storage.utils.AzureStorageUtils.getProxyOptions;
 
 @PrimaryNodeOnly
 @TriggerSerially
@@ -264,6 +265,13 @@ public class ListAzureDataLakeStorage extends 
AbstractListAzureProcessor<ADLSFil
 
     private List<ADLSFileInfo> performListing(final ProcessContext context, 
final Long minTimestamp, final ListingMode listingMode,
                                               final boolean applyFilters) 
throws IOException {
+        final DataLakeServiceClientFactory currentClientFactory;
+        if (ListingMode.CONFIGURATION_VERIFICATION == listingMode) {
+            currentClientFactory = new 
DataLakeServiceClientFactory(getLogger(), getProxyOptions(context));
+        } else {
+            currentClientFactory = clientFactory;
+        }
+
         try {
             final String fileSystem = evaluateFileSystemProperty(FILESYSTEM, 
context);
             final String baseDirectory = evaluateDirectoryProperty(DIRECTORY, 
context);
@@ -276,7 +284,7 @@ public class ListAzureDataLakeStorage extends 
AbstractListAzureProcessor<ADLSFil
 
             final ADLSCredentialsDetails credentialsDetails = 
credentialsService.getCredentialsDetails(Collections.emptyMap());
 
-            final DataLakeServiceClient storageClient = 
clientFactory.getStorageClient(credentialsDetails);
+            final DataLakeServiceClient storageClient = 
currentClientFactory.getStorageClient(credentialsDetails);
             final DataLakeFileSystemClient fileSystemClient = 
storageClient.getFileSystemClient(fileSystem);
 
             final ListPathsOptions options = new ListPathsOptions();