diff --git a/protempa-framework/src/main/java/org/protempa/HandleQueryResultThread.java b/protempa-framework/src/main/java/org/protempa/HandleQueryResultThread.java
index <HASH>..<HASH> 100644
--- a/protempa-framework/src/main/java/org/protempa/HandleQueryResultThread.java
+++ b/protempa-framework/src/main/java/org/protempa/HandleQueryResultThread.java
@@ -100,6 +100,7 @@ class HandleQueryResultThread extends AbstractThread {
         } catch (QueryResultsHandlerProcessingException ex) {
             log(Level.FINER, "Query results handler threw exception", ex);
             exceptions.add(new QueryException(query.getName(), ex));
+            producerThread.interrupt();
         } catch (QueryResultsHandlerCloseException ex) {
             log(Level.FINER, "Query results handler close threw exception", ex);
             exceptions.add(new QueryException(query.getName(), ex));
Fix bug where exception in QueryResultsHandler.start() causes job to hang without any reported errors.