Fix thread leak due to created executors never being shutdown

OHNLP · Mar 8, 2023 · cc9f881 · cc9f881
1 parent acb33fe
commit cc9f881
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>org.ohnlp.medtagger</groupId>
     <artifactId>medtagger</artifactId>
-    <version>1.0.54</version>
+    <version>1.0.55</version>
     <description>The MedTagger biomedical information extraction pipeline</description>
 
 

diff --git a/src/main/java/org/ohnlp/medtagger/backbone/MedTaggerBackboneTransform.java b/src/main/java/org/ohnlp/medtagger/backbone/MedTaggerBackboneTransform.java
@@ -225,6 +225,7 @@ public void processElement(@Element Row input, OutputReceiver<Row> output) {
                 if (t != null) {
                     throw new RuntimeException(t);
                 }
+                nlpExecutor.shutdownNow();
             } catch (InterruptedException | ExecutionException | TimeoutException e) {
                 System.out.println("Skipping document " + id + " due to NLP run taking longer than 30 seconds");
                 future.cancel(true);