This is an automated email from the ASF dual-hosted git repository.
pvillard31 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 d2beec6a54d NIFI-16460 Corrected logging statements where the number
of placeholders did not match the number of arguments. (#11819)
d2beec6a54d is described below
commit d2beec6a54d212532f4b6691eae08b52f9e735c2
Author: dan-s1 <[email protected]>
AuthorDate: Tue Oct 20 07:36:12 2026 -0400
NIFI-16460 Corrected logging statements where the number of placeholders
did not match the number of arguments. (#11819)
---
.../bootstrap/configuration/ConfigurationChangeCoordinator.java | 2 +-
.../src/main/java/org/apache/nifi/remote/client/PeerSelector.java | 2 +-
.../org/apache/nifi/remote/client/socket/EndpointConnectionPool.java | 2 +-
.../cluster/leader/zookeeper/CuratorLeaderElectionManager.java | 2 +-
.../org/apache/nifi/provenance/index/lucene/MigrateDefunctIndex.java | 4 ++--
.../src/main/java/org/apache/nifi/provenance/lucene/LineageQuery.java | 2 +-
.../org/apache/nifi/provenance/lucene/LuceneEventIndexSearcher.java | 2 +-
.../java/org/apache/nifi/provenance/lucene/StandardIndexManager.java | 2 +-
.../src/main/java/org/apache/nifi/groups/StandardProcessGroup.java | 2 +-
.../org/apache/nifi/persistence/FlowConfigurationArchiveManager.java | 4 ++--
.../main/java/org/apache/nifi/remote/SocketRemoteSiteListener.java | 2 +-
.../main/java/org/apache/nifi/registry/bootstrap/RunNiFiRegistry.java | 4 ++--
12 files changed, 15 insertions(+), 15 deletions(-)
diff --git
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
index 5f07b5ea4ba..3308730aeea 100644
---
a/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
+++
b/minifi/minifi-bootstrap/src/main/java/org/apache/nifi/minifi/bootstrap/configuration/ConfigurationChangeCoordinator.java
@@ -87,7 +87,7 @@ public class ConfigurationChangeCoordinator implements
Closeable, ConfigurationC
return listenerHandleResult;
} catch (ConfigurationChangeException ex) {
ListenerHandleResult listenerHandleResult = new
ListenerHandleResult(listener, ex);
- LOGGER.error("Listener notification result {} with failure {}",
listenerHandleResult, ex);
+ LOGGER.error("Listener notification result {} with failure",
listenerHandleResult, ex);
return listenerHandleResult;
}
}
diff --git
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/PeerSelector.java
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/PeerSelector.java
index cb9590cb71d..533cb4fe7fe 100644
---
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/PeerSelector.java
+++
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/PeerSelector.java
@@ -126,7 +126,7 @@ public class PeerSelector {
}
this.peerStatusCache = restoredPeerStatusCache;
} catch (final IOException ioe) {
- logger.warn("Failed to recover peer statuses from {} due to {};
will continue without loading information from file",
+ logger.warn("Failed to recover peer statuses from {}; will
continue without loading information from file",
peerPersistence.getClass().getSimpleName(), ioe);
}
}
diff --git
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
index bf676a26295..53b87e2177f 100644
---
a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
+++
b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
@@ -491,7 +491,7 @@ public class EndpointConnectionPool implements
PeerStatusProvider {
try {
connection.getSocketClientProtocol().shutdown(connection.getPeer());
} catch (final Exception e) {
- logger.debug("Failed to shut down {} using {} due to
{}",
+ logger.debug("Failed to shut down {} using {}",
connection.getSocketClientProtocol(),
connection.getPeer(), e);
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-framework-zookeeper-bundle/nifi-framework-zookeeper-leader-election/src/main/java/org/apache/nifi/framework/cluster/leader/zookeeper/CuratorLeaderElectionManager.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-framework-zookeeper-bundle/nifi-framework-zookeeper-leader-election/src/main/java/org/apache/nifi/framework/cluster/leader/zookeeper/CuratorLeaderElectionManager.java
index 05bbd0bcb98..8f7689ebfb8 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-framework-zookeeper-bundle/nifi-framework-zookeeper-leader-election/src/main/java/org/apache/nifi/framework/cluster/leader/zookeeper/CuratorLeaderElectionManager.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-framework-zookeeper-bundle/nifi-framework-zookeeper-leader-election/src/main/java/org/apache/nifi/framework/cluster/leader/zookeeper/CuratorLeaderElectionManager.java
@@ -520,7 +520,7 @@ public class CuratorLeaderElectionManager extends
TrackedLeaderElectionManager {
try {
listener.onStartLeading();
} catch (final Exception e) {
- logger.error("This node was elected Leader for Role '{}'
but failed to take leadership. Will relinquish leadership role. Failure was due
to: {}", roleName, e);
+ logger.error("This node was elected Leader for Role '{}'
but failed to take leadership. Will relinquish leadership role.", roleName, e);
setLeader(false);
Thread.sleep(1000L);
return;
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/MigrateDefunctIndex.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/MigrateDefunctIndex.java
index 02b26b5b8ed..e3e46c69949 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/MigrateDefunctIndex.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/index/lucene/MigrateDefunctIndex.java
@@ -101,7 +101,7 @@ public class MigrateDefunctIndex implements Runnable {
FileUtils.deleteFile(tempIndexDir, true);
} catch (final Exception e) {
logger.error("Attempted to rebuild index for {} but there
already exists a temporary Lucene 9 index at {}. " +
- "Attempted to delete existing temp directory but failed.
This index will not be rebuilt.", tempIndexDir, e);
+ "Attempted to delete existing temp directory but failed.
This index will not be rebuilt.", tempIndexDir, tempIndexDir, e);
return false;
}
}
@@ -112,7 +112,7 @@ public class MigrateDefunctIndex implements Runnable {
FileUtils.deleteFile(migratedIndexDir, true);
} catch (final Exception e) {
logger.error("Attempted to rebuild index for {} but there
already exists a Lucene 9 index at {}. " +
- "Attempted to delete existing Lucene 8 directory but
failed. This index will not be rebuilt.", migratedIndexDir, e);
+ "Attempted to delete existing Lucene 8 directory but
failed. This index will not be rebuilt.", migratedIndexDir, migratedIndexDir,
e);
return false;
}
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LineageQuery.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LineageQuery.java
index f05ef489ebb..27a6d3ed5ec 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LineageQuery.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LineageQuery.java
@@ -89,7 +89,7 @@ public class LineageQuery {
}
} catch (final FileNotFoundException fnfe) {
// nothing has been indexed yet, or the data has already aged off
- logger.warn("Attempted to search Provenance Index {} but could not
find the file due to {}", indexDirectory, fnfe);
+ logger.warn("Attempted to search Provenance Index {} but could not
find the file", indexDirectory, fnfe);
if (logger.isDebugEnabled()) {
logger.warn("", fnfe);
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LuceneEventIndexSearcher.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LuceneEventIndexSearcher.java
index d5d4e8436b3..b1b8740a8f3 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LuceneEventIndexSearcher.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/LuceneEventIndexSearcher.java
@@ -85,7 +85,7 @@ public class LuceneEventIndexSearcher implements
EventIndexSearcher {
try {
closeable.close();
} catch (final Exception e) {
- logger.warn("Failed to close {} due to {}", closeable, e);
+ logger.warn("Failed to close {}", closeable, e);
}
}
diff --git
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/StandardIndexManager.java
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/StandardIndexManager.java
index 76d660e582d..d38ea68d2f4 100644
---
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/StandardIndexManager.java
+++
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/StandardIndexManager.java
@@ -394,7 +394,7 @@ public class StandardIndexManager implements IndexManager {
try {
closeable.close();
} catch (final Exception e) {
- logger.warn("Failed to close {} due to {}", closeable, e);
+ logger.warn("Failed to close {}", closeable, e);
}
}
}
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
index 4f8970be64c..b35164561cc 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/groups/StandardProcessGroup.java
@@ -1113,7 +1113,7 @@ public final class StandardProcessGroup implements
ProcessGroup {
try {
remoteGroup.onRemove();
} catch (final Exception e) {
- LOG.warn("Failed to clean up resources for {} due to {}",
remoteGroup, e);
+ LOG.warn("Failed to clean up resources for {}", remoteGroup,
e);
}
remoteGroup.getInputPorts().forEach(scheduler::onPortRemoved);
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/persistence/FlowConfigurationArchiveManager.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/persistence/FlowConfigurationArchiveManager.java
index 5a85acc6b60..66590ae26b8 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/persistence/FlowConfigurationArchiveManager.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/persistence/FlowConfigurationArchiveManager.java
@@ -155,7 +155,7 @@ public class FlowConfigurationArchiveManager {
try {
totalArchiveSize.getAndAdd(Files.size(p));
} catch (IOException e) {
- logger.warn("Failed to get file size of {} due to {}",
p, e);
+ logger.warn("Failed to get file size of {}", p, e);
}
return true;
}
@@ -188,7 +188,7 @@ public class FlowConfigurationArchiveManager {
try {
Files.delete(archives.get(i));
} catch (IOException e) {
- logger.warn("Failed to delete {} to reduce storage usage, due
to {}", archives.get(i), e);
+ logger.warn("Failed to delete {} to reduce storage usage",
archives.get(i), e);
}
});
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/SocketRemoteSiteListener.java
b/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/SocketRemoteSiteListener.java
index d8f8f95ea7b..02e55a25c91 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/SocketRemoteSiteListener.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/SocketRemoteSiteListener.java
@@ -242,7 +242,7 @@ public class SocketRemoteSiteListener implements
RemoteSiteListener {
try {
peer.close();
} catch (final IOException e) {
- LOG.warn("Failed to close {} due to {}",
peer, e);
+ LOG.warn("Failed to close {}", peer, e);
}
// no need to shutdown protocol because we
failed to perform handshake
diff --git
a/nifi-registry/nifi-registry-core/nifi-registry-bootstrap/src/main/java/org/apache/nifi/registry/bootstrap/RunNiFiRegistry.java
b/nifi-registry/nifi-registry-core/nifi-registry-bootstrap/src/main/java/org/apache/nifi/registry/bootstrap/RunNiFiRegistry.java
index c4702b2e478..853966bdc3f 100644
---
a/nifi-registry/nifi-registry-core/nifi-registry-bootstrap/src/main/java/org/apache/nifi/registry/bootstrap/RunNiFiRegistry.java
+++
b/nifi-registry/nifi-registry-core/nifi-registry-bootstrap/src/main/java/org/apache/nifi/registry/bootstrap/RunNiFiRegistry.java
@@ -714,7 +714,7 @@ public class RunNiFiRegistry {
}
} catch (final IOException ioe) {
if (pid == null) {
- logger.error("Failed to send shutdown command to port {} due
to {}. No PID found for the NiFi Registry process, so unable to kill process; "
+ logger.error("Failed to send shutdown command to port {}. No
PID found for the NiFi Registry process, so unable to kill process; "
+ "the process should be killed manually.", port, ioe);
} else {
logger.error("Failed to send shutdown command to port {} due
to {}. Will kill the NiFi Registry Process with PID {}.", port, ioe, pid);
@@ -1136,7 +1136,7 @@ public class RunNiFiRegistry {
try {
savePidProperties(nifiProps, defaultLogger);
} catch (final IOException ioe) {
- defaultLogger.warn("Apache NiFi Registry has started but failed to
persist NiFi Registry Port information to {} due to {}",
statusFile.getAbsolutePath(), ioe);
+ defaultLogger.warn("Apache NiFi Registry has started but failed to
persist NiFi Registry Port information to {}", statusFile.getAbsolutePath(),
ioe);
}
defaultLogger.info("Apache NiFi Registry now running and listening for
Bootstrap requests on port {}", port);
