Github user ilooner commented on a diff in the pull request:
https://github.com/apache/drill/pull/1023#discussion_r149168081
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java ---
@@ -828,8 +828,13 @@ public void close() throws Exception {
queryManager.writeFinalProfile(uex);
}
- // Remove the Foreman from the running query list.
- bee.retireForeman(Foreman.this);
+ try {
+ queryContext.close();
+ } catch (Exception e) {
+ final String message = String.format("Unable to close query
context for query {}",
+ QueryIdHelper.getQueryId(queryId));
+ logger.error(message, e);
--- End diff --
Done
---
