Skip to content

Commit 40bbb87

Browse files
committed
Delete API: Using refresh parameter might not refresh delete operation on replica, closes elastic#1047.
1 parent 8417580 commit 40bbb87

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

modules/elasticsearch/src/main/java/org/elasticsearch/action/delete/TransportDeleteAction.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,6 +174,8 @@ private void innerExecute(final DeleteRequest request, final ActionListener<Dele
174174
Engine.Delete delete = indexShard.prepareDelete(request.type(), request.id(), request.version())
175175
.origin(Engine.Operation.Origin.REPLICA);
176176

177+
indexShard.delete(delete);
178+
177179
if (request.refresh()) {
178180
try {
179181
indexShard.refresh(new Engine.Refresh(false));
@@ -182,7 +184,6 @@ private void innerExecute(final DeleteRequest request, final ActionListener<Dele
182184
}
183185
}
184186

185-
indexShard.delete(delete);
186187
}
187188

188189
@Override protected ShardIterator shards(ClusterState clusterState, DeleteRequest request) {

0 commit comments

Comments
 (0)