From 7cfcf080d58cfc0025fcd639fbfec586ed94d2a8 Mon Sep 17 00:00:00 2001 From: Chris Earle Date: Fri, 9 Jun 2017 11:36:26 -0400 Subject: [PATCH 1/2] "shard started" should show index and shard ID 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. --- .../elasticsearch/cluster/action/shard/ShardStateAction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java b/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java index 8973890021f7a..d0fe29f641fa2 100644 --- a/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java +++ b/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java @@ -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.shardId, request, ClusterStateTaskConfig.build(Priority.URGENT), shardStartedClusterStateTaskExecutor, From 3f9d7e6418cc890eb9371fa68f1c134d0175ad6f Mon Sep 17 00:00:00 2001 From: Chris Earle Date: Fri, 9 Jun 2017 12:50:32 -0400 Subject: [PATCH 2/2] add the entire shard request rather than just index and shard id --- .../elasticsearch/cluster/action/shard/ShardStateAction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java b/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java index d0fe29f641fa2..543118a172f95 100644 --- a/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java +++ b/core/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java @@ -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 " + request.shardId, + "shard-started " + request, request, ClusterStateTaskConfig.build(Priority.URGENT), shardStartedClusterStateTaskExecutor,