Skip to content

Commit fe39d11

Browse files
committed
Logging in shard state action
This commit adds a trace log on a cluster state update while waiting for a new master, and changes the log level on cluster service close to the warn level.
1 parent efb1426 commit fe39d11

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,12 +137,15 @@ protected void waitForNewMasterAndRetry(ClusterStateObserver observer, ShardRout
137137
observer.waitForNextChange(new ClusterStateObserver.Listener() {
138138
@Override
139139
public void onNewClusterState(ClusterState state) {
140+
if (logger.isTraceEnabled()) {
141+
logger.trace("new cluster state [{}] after waiting for master election to fail shard [{}]", shardRoutingEntry.getShardRouting().shardId(), state.prettyPrint(), shardRoutingEntry);
142+
}
140143
sendShardFailed(observer, shardRoutingEntry, listener);
141144
}
142145

143146
@Override
144147
public void onClusterServiceClose() {
145-
logger.error("{} node closed while handling failed shard [{}]", shardRoutingEntry.failure, shardRoutingEntry.getShardRouting().getId(), shardRoutingEntry.getShardRouting());
148+
logger.warn("{} node closed while handling failed shard [{}]", shardRoutingEntry.failure, shardRoutingEntry.getShardRouting().getId(), shardRoutingEntry.getShardRouting());
146149
listener.onShardFailedFailure(new NodeClosedException(clusterService.localNode()));
147150
}
148151

0 commit comments

Comments
 (0)