[SYSTEMDS-3899] Avoid blocking entire input processed

Author: j143

src/main/java/org/apache/sysds/runtime/instructions/ooc/UnaryOOCInstruction.java

@@ -65,7 +65,7 @@ public void processInstruction( ExecutionContext ec ) {
 
         ExecutorService pool = CommonThreadPool.get();
         try {
-            Future<?> task =pool.submit(() -> {
+            pool.submit(() -> {
                 IndexedMatrixValue tmp = null;
                 try {
                     while ((tmp = qIn.dequeueTask()) != LocalTaskQueue.NO_MORE_TASKS) {
@@ -80,9 +80,8 @@ public void processInstruction( ExecutionContext ec ) {
                     throw new DMLRuntimeException(ex);
                 }
             });
-            task.get();
-        } catch (ExecutionException | InterruptedException e) {
-            throw new RuntimeException(e);
+        } catch (Exception ex) {
+            throw new DMLRuntimeException(ex);
         } finally {
             pool.shutdown();
         }