From 15cf7a236118aa4938fd8f6fe91a00b8d46045ec Mon Sep 17 00:00:00 2001
From: kimchy <kimchy@gmail.com>
Date: Wed, 21 Jul 2010 01:53:00 +0300
Subject: [PATCH] initialize the nodes before a possible retry, so we have the
 local node id for it

---
 .../replication/TransportShardReplicationOperationAction.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/replication/TransportShardReplicationOperationAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/replication/TransportShardReplicationOperationAction.java
index 5d31fd231f4..37866f1f30a 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/replication/TransportShardReplicationOperationAction.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/replication/TransportShardReplicationOperationAction.java
@@ -246,11 +246,11 @@ public abstract class TransportShardReplicationOperationAction<Request extends S
          */
         public boolean start(final boolean fromClusterEvent) throws ElasticSearchException {
             ClusterState clusterState = clusterService.state();
+            nodes = clusterState.nodes();
             if (!indicesService.hasIndex(request.index()) || !clusterState.routingTable().hasIndex(request.index())) {
                 retryPrimary(fromClusterEvent, null);
                 return false;
             }
-            nodes = clusterState.nodes();
             try {
                 shards = shards(clusterState, request);
             } catch (Exception e) {