KYLO-2818: fix for bad duration in Merge Table processor

abandaru · Oct 23, 2018 · f42197f · f42197f
1 parent 2e38184
commit f42197f
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/...ore-processors/src/main/java/com/thinkbiganalytics/nifi/v2/ingest/AbstractMergeTable.java b/...ore-processors/src/main/java/com/thinkbiganalytics/nifi/v2/ingest/AbstractMergeTable.java
@@ -314,8 +314,11 @@ public void onTrigger(final ProcessContext context, final ProcessSession session
             mergeStrategyValue = STRATEGY_DEDUPE_MERGE;
         }
 
-        logger.info(
-            "Merge strategy: " + mergeStrategyValue + " Using Source: " + sourceTable + " Target: " + targetTable + " feed partition:" + feedPartitionValue + " partSpec: " + partitionSpecString);
+        logger.info( "Merge strategy: " + mergeStrategyValue
+            + " Using Source: " + sourceTable
+            + " Target: " + targetTable
+            + " feed partition:" + feedPartitionValue
+            + " partSpec: " + partitionSpecString);
 
         final StopWatch stopWatch = new StopWatch(true);
 
@@ -347,10 +350,15 @@ public void onTrigger(final ProcessContext context, final ProcessSession session
                 throw new UnsupportedOperationException("Failed to resolve the merge strategy");
             }
 
-            stopWatch.stop();
             session.getProvenanceReporter().modifyContent(flowFile, "Execution completed", stopWatch.getElapsed(TimeUnit.MILLISECONDS));
             flowFile = session.putAttribute(flowFile, PROVENANCE_EXECUTION_STATUS_KEY, "Successful");
             release(blockingValue);
+            logger.info( "Execution completed: " + stopWatch.getElapsed(TimeUnit.MILLISECONDS)
+                         + " Merge strategy: " + mergeStrategyValue
+                         + " Using Source: " + sourceTable
+                         + " Target: " + targetTable
+                         + " feed partition:" + feedPartitionValue
+                         + " partSpec: " + partitionSpecString);
             session.transfer(flowFile, REL_SUCCESS);
 
         } catch (final Exception e) {