quick fix for issue elastic#55

williamrandolph · Jul 15, 2013 · 71d05aa · 71d05aa
1 parent 779006c
commit 71d05aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/elasticsearch/hadoop/rest/BufferedRestClient.java b/src/main/java/org/elasticsearch/hadoop/rest/BufferedRestClient.java
@@ -217,7 +217,7 @@ public Map<Shard, Node> getTargetShards() throws IOException {
         for (List<Map<String, Object>> shardGroup : info) {
             for (Map<String, Object> shardData : shardGroup) {
                 Shard shard = new Shard(shardData);
-                if (shard.getState().isStarted()) {
+                if (shard.getState().isStarted() && shard.isPrimary()) {
                     Node node = nodes.get(shard.getNode());
                     Assert.notNull(node, "Cannot find node with id [" + shard.getNode() + "]");
                     shards.put(shard, node);