Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -364,19 +364,16 @@ State getInFlightState(String asyncId) throws KeeperException, InterruptedExcept
// Unlikely race, but not impossible...
if (log.isInfoEnabled()) {
log.info(
"AsyncId ephemeral node "
+ getPath(asyncId)
+ " vanished from underneath us. Funny."); // nowarn
"AsyncId ephemeral node {} vanished from underneath us. Funny.", getPath(asyncId));
}
return State.NOT_FOUND;
}

if (bytes == null) {
// This is not expected. The ephemeral nodes are always created with content.
log.error(
"AsyncId ephemeral node "
+ getPath(asyncId)
+ " has null content. This is unexpected (bug)."); // nowarn
"AsyncId ephemeral node {} has null content. This is unexpected (bug).",
getPath(asyncId));
return State.NOT_FOUND;
}

Expand All @@ -387,11 +384,9 @@ State getInFlightState(String asyncId) throws KeeperException, InterruptedExcept
return State.SUBMITTED;
} else {
log.error(
"AsyncId ephemeral node "
+ getPath(asyncId)
+ " has unexpected content \""
+ content
+ "\". This is unexpected (bug)."); // nowarn
"AsyncId ephemeral node {} has unexpected content \"{}\". This is unexpected (bug).",
getPath(asyncId),
content);
return State.NOT_FOUND;
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -807,14 +807,11 @@ public void executeStateUpdates(SolrCloudManager scm, ZkStateReader zkStateReade
throws KeeperException, InterruptedException {
if (log.isDebugEnabled()) {
log.debug(
"Executing updates for collection "
+ collectionName
+ ", is creation="
+ isCollectionCreation
+ ", "
+ mutations.size()
+ " recorded mutations.",
new Exception("StackTraceOnly")); // nowarn
"Executing updates for collection {}, is creation={}, {} recorded mutations.",
collectionName,
isCollectionCreation,
mutations.size(),
new Exception("StackTraceOnly"));
}
if (mutations.isEmpty()) {
final String err =
Expand Down Expand Up @@ -925,10 +922,7 @@ public void computeUpdates(ClusterState clusterState, SolrZkClient client) {
if (docCollection == null) {
// This is possible but should be rare. Logging warn in case it is seen often and likely a
// sign of another issue
log.warn(
"Processing DOWNNODE, collection "
+ collectionName
+ " disappeared during iteration"); // nowarn
log.warn("Processing DOWNNODE, collection {} disappeared during iteration", collectionName);
}

if (result.isPresent()) {
Expand Down
5 changes: 2 additions & 3 deletions solr/core/src/java/org/apache/solr/cloud/Overseer.java
Original file line number Diff line number Diff line change
Expand Up @@ -1053,9 +1053,8 @@ public void offerStateUpdate(byte[] data) throws KeeperException, InterruptedExc
final ZkNodeProps message = ZkNodeProps.load(data);
final String operation = message.getStr(QUEUE_OPERATION);
log.error(
"Received unexpected message on Overseer cluster state updater for "
+ operation
+ " when distributed updates are configured"); // nowarn
"Received unexpected message on Overseer cluster state updater for {} when distributed updates are configured",
operation);
throw new RuntimeException(
"Message "
+ operation
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -708,7 +708,7 @@ private boolean isSuccessful() {
private void printTrackingMaps() {
if (log.isDebugEnabled()) {
log.debug("RunningTasks: {}", runningTasks.keySet());
log.debug("BlockedTasks: {}", blockedTasks.keySet()); // nowarn
log.debug("BlockedTasks: {}", blockedTasks.keySet());
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,7 @@ public void runConfigSetCommand(
action, (String) result.get(ConfigSetCmds.BASE_CONFIGSET));

if (log.isInfoEnabled()) {
log.info("Running Config Set API locally for " + action + " " + configSetName); // nowarn
log.info("Running Config Set API locally for {} {}", action, configSetName);
}

ConfigSetCommandRunner commandRunner =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,8 +60,8 @@ public void call(AdminCmdContext adminCmdContext, ZkNodeProps message, NamedList
// No Overseer (not accessible from Collection API command execution in any case) so this
// command can't be run...
log.error(
"Cluster is running with distributed Collection API execution. Ignoring Collection API operation "
+ operation); // nowarn
"Cluster is running with distributed Collection API execution. Ignoring Collection API operation {}",
operation);
return;
}
ZkStateReader zkStateReader = ccc.getZkStateReader();
Expand Down
4 changes: 1 addition & 3 deletions solr/core/src/java/org/apache/solr/handler/IndexFetcher.java
Original file line number Diff line number Diff line change
Expand Up @@ -508,9 +508,7 @@ IndexFetchResult fetchLatestIndex(boolean forceReplication, boolean forceCoreRel

if (log.isInfoEnabled()) {
log.info("Follower's generation: {}", commit.getGeneration());
log.info(
"Follower's version: {}",
IndexDeletionPolicyWrapper.getCommitTimestamp(commit)); // nowarn
log.info("Follower's version: {}", IndexDeletionPolicyWrapper.getCommitTimestamp(commit));
}

// Leader's version is 0 and generation is 0 - not open for replication
Expand Down
Loading