add missing exception handling within SPARQLProtocolWorker

dice-group · Sep 22, 2023 · 8f83893 · 8f83893
1 parent e2baf7d
commit 8f83893
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/org/aksw/iguana/cc/worker/impl/SPARQLProtocolWorker.java b/src/main/java/org/aksw/iguana/cc/worker/impl/SPARQLProtocolWorker.java
@@ -246,7 +246,7 @@ public CompletableFuture<Result> start() {
         }, executor);
     }
 
-    private ExecutionStats executeQuery(Duration timeout, boolean discardOnFailure)  {
+    private ExecutionStats executeQuery(Duration timeout, boolean discardOnFailure) {
         HttpExecutionResult result = executeHttpRequest(timeout);
         Optional<Integer> statuscode = Optional.empty();
         if (result.response().isPresent())
@@ -260,7 +260,12 @@ private ExecutionStats executeQuery(Duration timeout, boolean discardOnFailure)
                 this.responseBodybbaos = new BigByteArrayOutputStream();
             }
         }
-        this.responseBodybbaos.reset();
+
+        try {
+            this.responseBodybbaos.reset();
+        } catch (IOException e) {
+            this.responseBodybbaos = new BigByteArrayOutputStream();
+        }
 
         if (!result.completed() && discardOnFailure) {
             LOGGER.debug("{}\t:: Discarded execution, because the time limit has been reached: [queryID={}]", this, result.queryID);