Skip to content

Commit 665e95c

Browse files
committed
Update after review
1 parent 502a327 commit 665e95c

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

x-pack/plugin/async-search/src/main/java/org/elasticsearch/xpack/search/AsyncSearchTask.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -387,11 +387,12 @@ public static AsyncStatusResponse getStatusResponse(AsyncSearchTask asyncTask) {
387387
public void close() {
388388
if (logger.isDebugEnabled()) {
389389
logger.debug(
390-
"AsyncSearchTask.close(): byThread={}, asyncId={}, taskId={}, hasCompleted={}",
390+
"AsyncSearchTask.close(): byThread={}, asyncId={}, taskId={}, hasCompleted={}, stack={}",
391391
Thread.currentThread().getName(),
392392
searchId != null ? searchId.getEncoded() : "<null>",
393393
getId(),
394-
hasCompleted
394+
hasCompleted,
395+
new Exception().getStackTrace()
395396
);
396397
}
397398
Releasables.close(searchResponse);

x-pack/plugin/async-search/src/main/java/org/elasticsearch/xpack/search/MutableSearchResponse.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -495,10 +495,11 @@ private String getShardsInResponseMismatchInfo(SearchResponse response, boolean
495495
public synchronized void close() {
496496
if (logger.isDebugEnabled()) {
497497
logger.debug(
498-
"MutableSearchResponse.close(): byThread={}, finalResponsePresent={}, clusterResponsesCount={},",
498+
"MutableSearchResponse.close(): byThread={}, finalResponsePresent={}, clusterResponsesCount={}, stack={}",
499499
Thread.currentThread().getName(),
500500
finalResponse != null,
501-
clusterResponses != null ? clusterResponses.size() : 0
501+
clusterResponses != null ? clusterResponses.size() : 0,
502+
new Exception().getStackTrace()
502503
);
503504
}
504505

0 commit comments

Comments
 (0)