Percolate / Analyzer API can hang if it fails to execute, closes #1457.
This commit is contained in:
parent
e0acf13a12
commit
3da6e0a5b0
|
@ -142,6 +142,7 @@ public abstract class TransportSingleCustomOperationAction<Request extends Singl
|
|||
Response response = shardOperation(request, shard.id());
|
||||
listener.onResponse(response);
|
||||
} catch (Exception e) {
|
||||
shardsIt.reset();
|
||||
onFailure(shard, e);
|
||||
}
|
||||
}
|
||||
|
@ -153,6 +154,7 @@ public abstract class TransportSingleCustomOperationAction<Request extends Singl
|
|||
listener.onResponse(response);
|
||||
return;
|
||||
} catch (Exception e) {
|
||||
shardsIt.reset();
|
||||
onFailure(shard, e);
|
||||
}
|
||||
}
|
||||
|
@ -204,6 +206,8 @@ public abstract class TransportSingleCustomOperationAction<Request extends Singl
|
|||
onFailure(shard, e);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
perform(lastException);
|
||||
}
|
||||
} else {
|
||||
DiscoveryNode node = nodes.get(shard.currentNodeId());
|
||||
|
|
Loading…
Reference in New Issue