"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "server/src/main/java/org/elasticsearch/action/search/FetchSearchPhase.java" between
elasticsearch-6.8.2-src.tar.gz and elasticsearch-6.8.3-src.tar.gz

About: elasticsearch is a Distributed, RESTful, Search Engine built on top of Apache Lucene. Source package (GitHub).

FetchSearchPhase.java  (elasticsearch-6.8.2-src):FetchSearchPhase.java  (elasticsearch-6.8.3-src)
skipping to change at line 166 skipping to change at line 166
} }
private void executeFetch(final int shardIndex, final SearchShardTarget shar dTarget, private void executeFetch(final int shardIndex, final SearchShardTarget shar dTarget,
final CountedCollector<FetchSearchResult> counter, final CountedCollector<FetchSearchResult> counter,
final ShardFetchSearchRequest fetchSearchRequest, final QuerySearchResult querySearchResult, final ShardFetchSearchRequest fetchSearchRequest, final QuerySearchResult querySearchResult,
final Transport.Connection connection) { final Transport.Connection connection) {
context.getSearchTransport().sendExecuteFetch(connection, fetchSearchReq uest, context.getTask(), context.getSearchTransport().sendExecuteFetch(connection, fetchSearchReq uest, context.getTask(),
new SearchActionListener<FetchSearchResult>(shardTarget, shardIndex) { new SearchActionListener<FetchSearchResult>(shardTarget, shardIndex) {
@Override @Override
public void innerOnResponse(FetchSearchResult result) { public void innerOnResponse(FetchSearchResult result) {
counter.onResult(result); try {
counter.onResult(result);
} catch (Exception e) {
context.onPhaseFailure(FetchSearchPhase.this, "", e);
}
} }
@Override @Override
public void onFailure(Exception e) { public void onFailure(Exception e) {
try { try {
logger.debug(() -> new ParameterizedMessage("[{}] Failed to execute fetch phase", fetchSearchRequest.id()), e); logger.debug(() -> new ParameterizedMessage("[{}] Failed to execute fetch phase", fetchSearchRequest.id()), e);
counter.onFailure(shardIndex, shardTarget, e); counter.onFailure(shardIndex, shardTarget, e);
} finally { } finally {
// the search context might not be cleared on the node w here the fetch was executed for example // the search context might not be cleared on the node w here the fetch was executed for example
// because the action was rejected by the thread pool. i n this case we need to send a dedicated // because the action was rejected by the thread pool. i n this case we need to send a dedicated
 End of changes. 1 change blocks. 
1 lines changed or deleted 5 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)