Fork it over

jasontedor · Sep 13, 2018 · d4f8a98 · d4f8a98
1 parent 669bd24
commit d4f8a98
Showing 1 changed file with 1 addition and 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
@@ -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);
             }
         }