Merge pull request #1729 from dnwick/master

Add debug logs
siddhi-io · Jun 1, 2021 · d366e24 · d366e24
2 parents a66c41a + 124b0be
commit d366e24
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/.../java/io/siddhi/core/aggregation/persistedaggregation/CudStreamProcessorQueueManager.java b/.../java/io/siddhi/core/aggregation/persistedaggregation/CudStreamProcessorQueueManager.java
@@ -50,15 +50,24 @@ public void run() {
                 log.warn("Thread interrupted. Error when trying to retrieve queued values." + e.getMessage());
             }
             if (null != queuedCudStreamProcessor) {
+                if (log.isDebugEnabled()) {
+                    log.debug("Current queue size is = " + cudStreamProcessorQueue.size());
+                }
                 int i = 0;
                 while (true) {
                     i++;
                     try {
                         ComplexEventChunk complexEventChunk = new ComplexEventChunk();
                         complexEventChunk.add(queuedCudStreamProcessor.getStreamEvent());
+                        if (log.isDebugEnabled()) {
+                            log.debug("Starting processing for duration " + queuedCudStreamProcessor.getDuration());
+                        }
                         queuedCudStreamProcessor.getCudStreamProcessor().
                                 process(complexEventChunk);
                         complexEventChunk.clear();
+                        if (log.isDebugEnabled()) {
+                            log.debug("End processing for duration " + queuedCudStreamProcessor.getDuration());
+                        }
                         break;
                     } catch (Exception e) {
                         if (e.getCause() instanceof SQLException) {