NIFI-14510 Bump Azure SDK to 1.2.34, parquet to 1.15.2, commons config to 2.12.0, and others (#9913)

- Microsoft Azure Kusto from 5.2.0 to 6.0.2 - https://github.com/Azure/azure-kusto-java/releases/tag/v6.0.2
- Azure SDK from 1.2.33 to 1.2.34 - https://github.com/Azure/azure-sdk-for-java/releases/tag/azure-sdk-bom_1.2.34
- Box SDK from 4.16.0 to 4.16.1 - https://github.com/box/box-java-sdk/releases/tag/v4.16.1
- Google Drive from v3-rev20250329-2.0.0 to v3-rev20250427-2.0.0 - https://github.com/googleapis/google-api-java-client-services/blob/main/clients/google-api-services-drive/v3/2.0.0/README.md
- parquet-avro from 1.15.1 to 1.15.2 - https://github.com/apache/parquet-java/releases/tag/apache-parquet-1.15.2
- Spring Data Redis from 3.4.1 to 3.4.5 - https://github.com/spring-projects/spring-data-redis/releases/tag/3.4.5
- Nimbus JWT from 10.0.2 to 10.2 - https://bitbucket.org/connect2id/nimbus-jose-jwt/src/master/CHANGELOG.txt
- Apache Lucene from 10.2.0 to 10.2.1 - https://github.com/apache/lucene/releases/tag/releases%2Flucene%2F10.2.1
- MySQL Connector from 9.2.0 to 9.3.0 - https://dev.mysql.com/doc/relnotes/connector-j/en/news-9-3-0.html
- AWS SDK v1 from 1.12.782 to 1.12.783 - https://github.com/aws/aws-sdk-java-v2/blob/master/CHANGELOG.md
- AWS SDK v2 from 2.31.30 to 2.31.34 - https://github.com/aws/aws-sdk-java-v2/blob/master/CHANGELOG.md
- io fabric8 k8s from 7.1.0 to 7.2.0 - https://github.com/fabric8io/kubernetes-client/blob/main/CHANGELOG.md#720-2025-04-30
- Apache Commons Configuration from 2.11.0 to 2.12.0 - https://commons.apache.org/proper/commons-configuration/changes.html#a2.12.0
- jsoup from 1.19.1 to 1.20.1 - https://github.com/jhy/jsoup/blob/master/CHANGES.md#1201-2025-04-29

Signed-off-by: David Handermann <[email protected]>

Author: pvillard31

nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/pom.xml

@@ -51,7 +51,6 @@
         <dependency>
             <groupId>org.apache.nifi</groupId>
             <artifactId>nifi-record</artifactId>
-            <version>2.5.0-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.apache.nifi</groupId>
@@ -128,12 +127,12 @@
         <dependency>
             <groupId>com.microsoft.azure.kusto</groupId>
             <artifactId>kusto-data</artifactId>
-            <version>5.2.0</version>
+            <version>6.0.2</version>
         </dependency>
         <dependency>
             <groupId>com.microsoft.azure.kusto</groupId>
             <artifactId>kusto-ingest</artifactId>
-            <version>5.2.0</version>
+            <version>6.0.2</version>
         </dependency>
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>

nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/data/explorer/StandardKustoIngestService.java

@@ -18,6 +18,7 @@
 
 import com.microsoft.azure.kusto.data.Client;
 import com.microsoft.azure.kusto.data.ClientFactory;
+import com.microsoft.azure.kusto.data.KustoOperationResult;
 import com.microsoft.azure.kusto.data.KustoResultColumn;
 import com.microsoft.azure.kusto.data.KustoResultSetTable;
 import com.microsoft.azure.kusto.data.auth.ConnectionStringBuilder;
@@ -164,13 +165,7 @@ public final void onStopped() {
             }
         }
         if (this.executionClient != null) {
-            try {
-                this.executionClient.close();
-            } catch (IOException e) {
-                getLogger().error("Closing Azure Data Explorer Execution Client failed", e);
-            } finally {
-                this.executionClient = null;
-            }
+            this.executionClient = null;
         }
     }
 
@@ -319,14 +314,16 @@ private KustoIngestQueryResponse executeQuery(final String databaseName, final S
 
         KustoIngestQueryResponse kustoIngestQueryResponse;
         try {
-            KustoResultSetTable kustoResultSetTable = this.executionClient.execute(databaseName, query).getPrimaryResults();
-            Map<Integer, List<String>> response = new HashMap<>();
+            final KustoOperationResult kustoOperationResult = this.executionClient.executeQuery(databaseName, query);
+            final KustoResultSetTable kustoResultSetTable = kustoOperationResult.getPrimaryResults();
+
+            final Map<Integer, List<String>> response = new HashMap<>();
             int rowCount = 0;
 
             // Add the received values to the new ingestion resources
             while (kustoResultSetTable.hasNext()) {
                 kustoResultSetTable.next();
-                List<String> rowData = new ArrayList<>();
+                final List<String> rowData = new ArrayList<>();
                 for (KustoResultColumn columnName : kustoResultSetTable.getColumns()) {
                     String data = kustoResultSetTable.getString(columnName.getOrdinal());
                     rowData.add(data);

nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/data/explorer/StandardKustoQueryService.java

@@ -112,11 +112,6 @@ public final void onStopped() {
         if (this.kustoClient == null) {
             getLogger().debug("Kusto Client not configured");
         } else {
-            try {
-                this.kustoClient.close();
-            } catch (final Exception e) {
-                getLogger().error("Kusto Client close failed", e);
-            }
             this.kustoClient = null;
         }
     }

nifi-extension-bundles/nifi-azure-bundle/pom.xml

@@ -28,7 +28,7 @@
 
     <properties>
         <!-- when changing the Azure SDK version, also update msal4j to the version that is required by azure-identity -->
-        <azure.sdk.bom.version>1.2.33</azure.sdk.bom.version>
+        <azure.sdk.bom.version>1.2.34</azure.sdk.bom.version>
         <msal4j.version>1.19.1</msal4j.version>
         <qpid.proton.version>0.34.1</qpid.proton.version>
     </properties>

nifi-extension-bundles/nifi-box-bundle/pom.xml

@@ -39,7 +39,7 @@
             <dependency>
                 <groupId>com.box</groupId>
                 <artifactId>box-java-sdk</artifactId>
-                <version>4.16.0</version>
+                <version>4.16.1</version>
             </dependency>
         </dependencies>
     </dependencyManagement>

nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/pom.xml

@@ -127,7 +127,7 @@
         <dependency>
             <groupId>com.google.apis</groupId>
             <artifactId>google-api-services-drive</artifactId>
-            <version>v3-rev20250329-2.0.0</version>
+            <version>v3-rev20250427-2.0.0</version>
         </dependency>
         <dependency>
             <groupId>com.tdunning</groupId>

nifi-extension-bundles/nifi-parquet-bundle/nifi-parquet-processors/pom.xml

@@ -78,7 +78,7 @@
         <dependency>
             <groupId>org.apache.parquet</groupId>
             <artifactId>parquet-avro</artifactId>
-            <version>1.15.1</version>
+            <version>1.15.2</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.xerial.snappy</groupId>

nifi-extension-bundles/nifi-redis-bundle/nifi-redis-utils/src/main/java/org/apache/nifi/redis/util/RedisUtils.java

@@ -29,6 +29,7 @@
 import org.apache.nifi.util.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.data.redis.connection.PoolException;
 import org.springframework.data.redis.connection.RedisClusterConfiguration;
 import org.springframework.data.redis.connection.RedisConfiguration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
@@ -46,6 +47,7 @@
 import redis.clients.jedis.JedisPoolConfig;
 
 import javax.net.ssl.SSLContext;
+
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.HashSet;
@@ -425,7 +427,12 @@ public static JedisConnectionFactory createConnectionFactory(final RedisConfig r
         }
 
         // need to call this to initialize the pool/connections
-        connectionFactory.afterPropertiesSet();
+        try {
+            connectionFactory.afterPropertiesSet();
+        } catch (PoolException e) {
+            LOGGER.warn("Could not pre-warm Redis pool (no Redis running?) – will connect lazily", e);
+        }
+
         return connectionFactory;
     }
 

nifi-extension-bundles/nifi-redis-bundle/pom.xml

@@ -25,7 +25,7 @@
     <packaging>pom</packaging>
 
     <properties>
-        <spring.data.redis.version>3.4.1</spring.data.redis.version>
+        <spring.data.redis.version>3.4.5</spring.data.redis.version>
         <jedis.version>5.2.0</jedis.version>
     </properties>
 

nifi-extension-bundles/nifi-standard-services/nifi-oauth2-provider-bundle/nifi-oauth2-provider-service/pom.xml

@@ -54,7 +54,7 @@
         <dependency>
             <groupId>com.nimbusds</groupId>
             <artifactId>nimbus-jose-jwt</artifactId>
-            <version>10.0.2</version>
+            <version>10.2</version>
             <exclusions>
                 <exclusion>
                     <groupId>com.google.crypto.tink</groupId>

nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/pom.xml

@@ -27,7 +27,7 @@
         <module>nifi-provenance-repository-nar</module>
     </modules>
     <properties>
-        <lucene.version>10.2.0</lucene.version>
+        <lucene.version>10.2.1</lucene.version>
     </properties>
     <dependencyManagement>
         <dependencies>

nifi-registry/nifi-registry-core/nifi-registry-test/pom.xml

@@ -62,7 +62,7 @@
         <dependency>
             <groupId>com.mysql</groupId>
             <artifactId>mysql-connector-j</artifactId>
-            <version>9.2.0</version>
+            <version>9.3.0</version>
             <exclusions>
                 <!-- Exclude unused protobuf-java -->
                 <exclusion>

pom.xml

@@ -109,10 +109,10 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <inceptionYear>2014</inceptionYear>
-        <com.amazonaws.version>1.12.782</com.amazonaws.version>
-        <software.amazon.awssdk.version>2.31.30</software.amazon.awssdk.version>
+        <com.amazonaws.version>1.12.783</com.amazonaws.version>
+        <software.amazon.awssdk.version>2.31.34</software.amazon.awssdk.version>
         <gson.version>2.13.1</gson.version>
-        <io.fabric8.kubernetes.client.version>7.1.0</io.fabric8.kubernetes.client.version>
+        <io.fabric8.kubernetes.client.version>7.2.0</io.fabric8.kubernetes.client.version>
         <kotlin.version>2.1.20</kotlin.version>
         <okhttp.version>4.12.0</okhttp.version>
         <okio.version>3.11.0</okio.version>
@@ -121,7 +121,7 @@
         <org.apache.commons.collections4.version>4.5.0</org.apache.commons.collections4.version>
         <org.apache.commons.compress.version>1.27.1</org.apache.commons.compress.version>
         <com.github.luben.zstd-jni.version>1.5.7-2</com.github.luben.zstd-jni.version>
-        <org.apache.commons.configuration.version>2.11.0</org.apache.commons.configuration.version>
+        <org.apache.commons.configuration.version>2.12.0</org.apache.commons.configuration.version>
         <org.apache.commons.lang3.version>3.17.0</org.apache.commons.lang3.version>
         <org.apache.commons.net.version>3.11.1</org.apache.commons.net.version>
         <org.apache.commons.io.version>2.19.0</org.apache.commons.io.version>
@@ -539,7 +539,7 @@
             <dependency>
                 <groupId>org.jsoup</groupId>
                 <artifactId>jsoup</artifactId>
-                <version>1.19.1</version>
+                <version>1.20.1</version>
             </dependency>
             <dependency>
                 <groupId>com.github.ben-manes.caffeine</groupId>