Skip to content

Commit 9c4e3d2

Browse files
committed
Add extra interrupt per coderabbit feedback
Signed-off-by: Simeon Widdis <sawiddis@amazon.com>
1 parent 88073bd commit 9c4e3d2

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

opensearch/src/main/java/org/opensearch/sql/opensearch/executor/OpenSearchQueryManager.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,8 @@ private void schedule(NodeClient client, Runnable task, TimeValue timeout) {
6262
try {
6363
task.run();
6464
timeoutTask.cancel();
65+
// Clear any leftover thread interrupts to keep the thread pool clean
66+
Thread.interrupted();
6567
} catch (Exception e) {
6668
timeoutTask.cancel();
6769

0 commit comments

Comments
 (0)