|
|
@@ -89,7 +89,7 @@ public class ShardStateAction extends AbstractComponent {
|
|
|
logger.warn("{} no master known for action [{}] for shard [{}]", shardRoutingEntry.getShardRouting().shardId(), actionName, shardRoutingEntry.getShardRouting());
|
|
|
waitForNewMasterAndRetry(actionName, observer, shardRoutingEntry, listener);
|
|
|
} else {
|
|
|
- logger.debug("{} sending [{}] to [{}] for shard [{}]", shardRoutingEntry.getShardRouting().getId(), actionName, masterNode.getId(), shardRoutingEntry);
|
|
|
+ logger.debug("{} sending [{}] to [{}] for shard [{}]", shardRoutingEntry.getShardRouting().shardId(), actionName, masterNode.getId(), shardRoutingEntry);
|
|
|
transportService.sendRequest(masterNode,
|
|
|
actionName, shardRoutingEntry, new EmptyTransportResponseHandler(ThreadPool.Names.SAME) {
|
|
|
@Override
|
|
|
@@ -144,7 +144,7 @@ public class ShardStateAction extends AbstractComponent {
|
|
|
|
|
|
@Override
|
|
|
public void onClusterServiceClose() {
|
|
|
- logger.warn("{} node closed while execution action [{}] for shard [{}]", shardRoutingEntry.failure, shardRoutingEntry.getShardRouting().getId(), actionName, shardRoutingEntry.getShardRouting());
|
|
|
+ logger.warn("{} node closed while execution action [{}] for shard [{}]", shardRoutingEntry.failure, shardRoutingEntry.getShardRouting().shardId(), actionName, shardRoutingEntry.getShardRouting());
|
|
|
listener.onFailure(new NodeClosedException(clusterService.localNode()));
|
|
|
}
|
|
|
|