From d4f8a9818525579bdac3a05083a81cf2b5ebc996 Mon Sep 17 00:00:00 2001
From: Jason Tedor <jason@tedor.me>
Date: Thu, 13 Sep 2018 14:50:30 -0400
Subject: [PATCH] Fork it over

---
 .../org/elasticsearch/xpack/ccr/action/ShardChangesAction.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java
index b059a86e4db19..6bc1f41b5ce49 100644
--- a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java
+++ b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java
@@ -306,7 +306,6 @@ protected void asyncShardOperation(
             final IndexShard indexShard = indexService.getShard(request.getShard().id());
             final SeqNoStats seqNoStats = indexShard.seqNoStats();
 
-
             if (request.getFromSeqNo() > seqNoStats.getGlobalCheckpoint()) {
                 assert request.getFromSeqNo() == 1 + seqNoStats.getGlobalCheckpoint();
                 indexShard.addGlobalCheckpointListener(
@@ -332,7 +331,7 @@ protected void asyncShardOperation(
                         },
                         request.getPollTimeout());
             } else {
-                listener.onResponse(shardOperation(request, shardId));
+                super.asyncShardOperation(request, shardId, listener);
             }
         }