Skip to content

Commit

Permalink
"shard started" should show index and shard ID (#25157)
Browse files Browse the repository at this point in the history
When the cluster state is updated with Shard Started entries, it simply adds "shard-started" as the source of the change.

This adds the index name and shard ID so that we can see who/what is spamming the changes when the index creation step has already left the cluster state.
  • Loading branch information
pickypg committed Jun 9, 2017
1 parent c292fdf commit 0907e56
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -375,7 +375,7 @@ private static class ShardStartedTransportHandler implements TransportRequestHan
public void messageReceived(ShardEntry request, TransportChannel channel) throws Exception {
logger.debug("{} received shard started for [{}]", request.shardId, request);
clusterService.submitStateUpdateTask(
"shard-started",
"shard-started " + request,
request,
ClusterStateTaskConfig.build(Priority.URGENT),
shardStartedClusterStateTaskExecutor,
Expand Down

0 comments on commit 0907e56

Please sign in to comment.