honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Always catch exceptions from TransportBroadcastOperationAction#newResponse (reduce phase)

Browse Source
This commit is contained in:
Martijn van Groningen 2013-08-15 13:15:52 +02:00
parent 174707061c
commit bfac2f575e
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/elasticsearch/action/support/broadcast/TransportBroadcastOperationAction.java
View File

@ -142,7 +142,11 @@ public abstract class TransportBroadcastOperationAction<Request extends Broadcas
public void start() { public void start() {
if (shardsIts.size() == 0) { if (shardsIts.size() == 0) {
// no shards // no shards
listener.onResponse(newResponse(request, new AtomicReferenceArray(0), clusterState)); try {
listener.onResponse(newResponse(request, new AtomicReferenceArray(0), clusterState));
} catch (Throwable e) {
listener.onFailure(e);
}
} }
request.beforeStart(); request.beforeStart();
// count the local operations, and perform the non local ones // count the local operations, and perform the non local ones
@ -313,7 +317,11 @@ public abstract class TransportBroadcastOperationAction<Request extends Broadcas
} }
void finishHim() { void finishHim() {
listener.onResponse(newResponse(request, shardsResponses, clusterState)); try {
listener.onResponse(newResponse(request, shardsResponses, clusterState));
} catch (Throwable e) {
listener.onFailure(e);
}
} }
void setFailure(ShardIterator shardIt, int shardIndex, Throwable t) { void setFailure(ShardIterator shardIt, int shardIndex, Throwable t) {