diff --git a/src/main/java/org/elasticsearch/rest/action/cat/RestShardsAction.java b/src/main/java/org/elasticsearch/rest/action/cat/RestShardsAction.java
index 5157df9cc72..df8055d55dd 100644
--- a/src/main/java/org/elasticsearch/rest/action/cat/RestShardsAction.java
+++ b/src/main/java/org/elasticsearch/rest/action/cat/RestShardsAction.java
@@ -108,17 +108,23 @@ public class RestShardsAction extends BaseRestHandler {
         for (ShardRouting shard : state.getState().routingTable().allShards()) {
             Row row = new Row();
             String pri = "r";
-            String host = "";
+            StringBuilder host = new StringBuilder();
             String docs = "";
             String size = "";
             String bytes = "";
             String nodeName = "";
 
             if (shard.assignedToNode()) {
-                host = ((InetSocketTransportAddress) state.getState().nodes().get(shard.currentNodeId()).address()).address().getHostString();
+                host.append(((InetSocketTransportAddress) state.getState().nodes().get(shard.currentNodeId()).address()).address().getHostString());
                 nodeName = state.getState().nodes().get(shard.currentNodeId()).name();
             }
 
+            if (shard.relocating()) {
+                host.append(" -> ");
+                host.append(((InetSocketTransportAddress) state.getState().nodes().get(shard.relocatingNodeId()).address()).address().getHostString());
+                host.append(state.getState().nodes().get(shard.relocatingNodeId()).name());
+            }
+
             if (null != stats.asMap().get(shard.globalId())) {
                 size = stats.asMap().get(shard.globalId()).getStore().size().toString();
                 bytes = new Long(stats.asMap().get(shard.globalId()).getStore().getSizeInBytes()).toString();
@@ -136,7 +142,7 @@ public class RestShardsAction extends BaseRestHandler {
                     .addCell(docs)
                     .addCell(size)
                     .addCell(bytes)
-                    .addCell(host)
+                    .addCell(host.toString())
                     .addCell(nodeName);
             tab.addRow(row);
         }