Improved the logging

java/com.sap.sse.datamining/src/com/sap/sse/datamining/impl/components/AbstractPartitioningParallelProcessor.java

@@ -20,6 +20,8 @@ public abstract class AbstractPartitioningParallelProcessor<InputType, WorkingTy
     private final Set<Processor<ResultType>> resultReceivers;
     private final ExecutorService executor;
     private final UnfinishedInstructionsCounter unfinishedInstructionsCounter;
+    
+    private boolean gotAborted = false;
 
     public AbstractPartitioningParallelProcessor(ExecutorService executor, Collection<Processor<ResultType>> resultReceivers) {
         this.executor = executor;
@@ -41,7 +43,9 @@ public abstract class AbstractPartitioningParallelProcessor<InputType, WorkingTy
                                 forwardResultToReceivers(result);
                             }
                         } catch (Exception e) {
-                            LOGGER.log(Level.FINEST, "An error occured during the processing of an instruction: ", e);
+                            if (!gotAborted || !(e instanceof InterruptedException)) {
+                                LOGGER.log(Level.FINEST, "An error occured during the processing of an instruction: ", e);
+                            }
                         } finally {
                             AbstractPartitioningParallelProcessor.this.unfinishedInstructionsCounter.decrement();
                         }
@@ -110,8 +114,10 @@ public abstract class AbstractPartitioningParallelProcessor<InputType, WorkingTy
     
     @Override
     public void abort() {
+        gotAborted = true;
         executor.shutdownNow();
         tellResultReceiversToAbort();
+        LOGGER.log(Level.INFO, "The processing got aborted.");
     }
 
     private void tellResultReceiversToAbort() {

java/com.sap.sse.datamining/src/com/sap/sse/datamining/impl/components/ProcessorQuery.java

@@ -29,7 +29,7 @@ public class ProcessorQuery<AggregatedType, DataSourceType> implements Query<Agg
 
     private final Object monitorObject = new Object();
     private boolean workIsDone = false;
-    private boolean processorTimedOut = true;
+    private boolean processorTimedOut = false;
 
     public ProcessorQuery(Executor executor, DataSourceType dataSource) {
         this.executor = executor;
@@ -91,7 +91,7 @@ public class ProcessorQuery<AggregatedType, DataSourceType> implements Query<Agg
                 }
             }
             workIsDone = false;
-            processorTimedOut = true;
+            processorTimedOut = false;
         }
     }
     
@@ -102,6 +102,7 @@ public class ProcessorQuery<AggregatedType, DataSourceType> implements Query<Agg
                 @Override
                 public void run() {
                     synchronized (monitorObject) {
+                        processorTimedOut = true;
                         monitorObject.notify();
                     }
                 }
@@ -134,7 +135,6 @@ public class ProcessorQuery<AggregatedType, DataSourceType> implements Query<Agg
         public void finish() throws InterruptedException {
             synchronized (monitorObject) {
                 workIsDone = true;
-                processorTimedOut = false;
                 monitorObject.notify();
             }
         }