diff --git a/nifi-external/nifi-spark-receiver/pom.xml b/nifi-external/nifi-spark-receiver/pom.xml index ddf3cf008c..531fa13582 100644 --- a/nifi-external/nifi-spark-receiver/pom.xml +++ b/nifi-external/nifi-spark-receiver/pom.xml @@ -22,9 +22,6 @@ org.apache.nifi nifi-spark-receiver - - 3.5.9 - diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/pom.xml b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/pom.xml index d06bfeb8f6..a3aaa8cf27 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/pom.xml +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/pom.xml @@ -175,6 +175,16 @@ nifi-flowfile-repo-serialization 1.17.0-SNAPSHOT + + + io.dropwizard.metrics + metrics-core + + + + org.xerial.snappy + snappy-java + org.apache.zookeeper zookeeper diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java index 4caf58d213..f19e12ef5d 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/state/server/ZooKeeperStateServer.java @@ -118,7 +118,8 @@ public class ZooKeeperStateServer extends ZooKeeperServerMain { embeddedZkServer.setMaxSessionTimeout(config.getMaxSessionTimeout()); connectionFactory = ServerCnxnFactory.createFactory(); - connectionFactory.configure(getAvailableSocketAddress(config), config.getMaxClientCnxns(), quorumPeerConfig.isSslQuorum()); + final int listenBacklog = quorumPeerConfig.getClientPortListenBacklog(); + connectionFactory.configure(getAvailableSocketAddress(config), config.getMaxClientCnxns(), listenBacklog, quorumPeerConfig.isSslQuorum()); connectionFactory.startup(embeddedZkServer); } catch (InterruptedException e) { Thread.currentThread().interrupt(); @@ -136,7 +137,8 @@ public class ZooKeeperStateServer extends ZooKeeperServerMain { try { transactionLog = new FileTxnSnapLog(quorumPeerConfig.getDataLogDir(), quorumPeerConfig.getDataDir()); connectionFactory = ServerCnxnFactory.createFactory(); - connectionFactory.configure(getAvailableSocketAddress(quorumPeerConfig), quorumPeerConfig.getMaxClientCnxns(), quorumPeerConfig.isSslQuorum()); + final int listenBacklog = quorumPeerConfig.getClientPortListenBacklog(); + connectionFactory.configure(getAvailableSocketAddress(quorumPeerConfig), quorumPeerConfig.getMaxClientCnxns(), listenBacklog, quorumPeerConfig.isSslQuorum()); quorumPeer = new QuorumPeer(); diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/leader/election/ITSecureClientZooKeeperFactory.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/leader/election/ITSecureClientZooKeeperFactory.java index b0a4f22c24..dc9f9fc810 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/leader/election/ITSecureClientZooKeeperFactory.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/leader/election/ITSecureClientZooKeeperFactory.java @@ -194,7 +194,7 @@ public class ITSecureClientZooKeeperFactory { ZooKeeperServer zkServer = new ZooKeeperServer(dataDir.toFile(), dataDir.toFile(), 2000); ServerCnxnFactory secureConnectionFactory = ServerCnxnFactory.createFactory(clientPort, -1); - secureConnectionFactory.configure(new InetSocketAddress(clientPort), -1, true); + secureConnectionFactory.configure(new InetSocketAddress(clientPort), -1, -1, true); secureConnectionFactory.startup(zkServer); return secureConnectionFactory; diff --git a/nifi-nar-bundles/nifi-framework-bundle/pom.xml b/nifi-nar-bundles/nifi-framework-bundle/pom.xml index 9a2417e5d8..9f827c8369 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-framework-bundle/pom.xml @@ -24,7 +24,6 @@ NiFi: Framework Bundle 5.2.1 - 3.5.9 nifi-framework @@ -535,6 +534,12 @@ cglib-nodep 3.3.0 + + + io.dropwizard.metrics + metrics-core + 4.1.12.1 + org.apache.zookeeper zookeeper diff --git a/nifi-nar-bundles/nifi-hive-bundle/pom.xml b/nifi-nar-bundles/nifi-hive-bundle/pom.xml index e8d306b884..60094dd704 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-hive-bundle/pom.xml @@ -109,7 +109,6 @@ ${hive3.version} 1.27.0 1.6.0 - 3.5.9 diff --git a/nifi-nar-bundles/nifi-ranger-bundle/pom.xml b/nifi-nar-bundles/nifi-ranger-bundle/pom.xml index 34608f7c80..882a64f9e6 100644 --- a/nifi-nar-bundles/nifi-ranger-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-ranger-bundle/pom.xml @@ -25,10 +25,6 @@ nifi-ranger-bundle pom - - 3.5.9 - - nifi-ranger-plugin nifi-ranger-nar diff --git a/nifi-nar-bundles/nifi-spark-bundle/pom.xml b/nifi-nar-bundles/nifi-spark-bundle/pom.xml index 96a1468fc6..b6c8f5c54c 100644 --- a/nifi-nar-bundles/nifi-spark-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-spark-bundle/pom.xml @@ -23,10 +23,6 @@ nifi-spark-bundle pom - - 3.5.9 - - nifi-livy-nar nifi-livy-controller-service-api-nar diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml index 42e5a3b39c..8d01ab2ef5 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml @@ -24,7 +24,6 @@ pom 2.7.3 - 3.5.9 nifi-hbase_1_1_2-client-service diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_2-client-service-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_2-client-service-bundle/pom.xml index b63e44bf2d..222a6ad0b4 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_2-client-service-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_2-client-service-bundle/pom.xml @@ -26,7 +26,6 @@ 2.2.2 - 3.5.9 diff --git a/nifi-registry/nifi-registry-extensions/nifi-registry-ranger/pom.xml b/nifi-registry/nifi-registry-extensions/nifi-registry-ranger/pom.xml index 75f8819ddf..2a3a7b04db 100644 --- a/nifi-registry/nifi-registry-extensions/nifi-registry-ranger/pom.xml +++ b/nifi-registry/nifi-registry-extensions/nifi-registry-ranger/pom.xml @@ -24,10 +24,6 @@ nifi-registry-ranger pom - - 3.5.9 - - nifi-registry-ranger-assembly nifi-registry-ranger-jersey-bundle diff --git a/nifi-toolkit/nifi-toolkit-zookeeper-migrator/pom.xml b/nifi-toolkit/nifi-toolkit-zookeeper-migrator/pom.xml index 9c8664b562..05691b571f 100644 --- a/nifi-toolkit/nifi-toolkit-zookeeper-migrator/pom.xml +++ b/nifi-toolkit/nifi-toolkit-zookeeper-migrator/pom.xml @@ -25,7 +25,6 @@ 5.2.1 - 3.5.9 diff --git a/pom.xml b/pom.xml index b2f8265866..bdc129c58c 100644 --- a/pom.xml +++ b/pom.xml @@ -135,6 +135,7 @@ 5.3.20 5.7.1 2.1.210 + 3.8.0