Skip to content

Commit

Permalink
Close stream manager when threads are done
Browse files Browse the repository at this point in the history
Signed-off-by: Harsha Vamsi Kalluri <[email protected]>
  • Loading branch information
harshavamsi committed Jan 30, 2025
1 parent cb6624a commit b484146
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -804,6 +804,8 @@ public ReducedQueryPhase reducedFromStream(
} catch (InterruptedException | ExecutionException e) {
Thread.currentThread().interrupt();
throw new RuntimeException("Error processing tickets in parallel", e);
} finally {
streamManager.close();
}

TotalHits totalHits = new TotalHits(totalRows, Relation.EQUAL_TO);
Expand Down

0 comments on commit b484146

Please sign in to comment.