diff --git a/src/java/azkaban/execapp/FlowRunner.java b/src/java/azkaban/execapp/FlowRunner.java
index <HASH>..<HASH> 100644
--- a/src/java/azkaban/execapp/FlowRunner.java
+++ b/src/java/azkaban/execapp/FlowRunner.java
@@ -694,6 +694,8 @@ public class FlowRunner extends EventHandler implements Runnable {
 						jobOutputProps.put(node.getJobId(), runner.getOutputProps());
 					}
 					
+					updateFlow();
+					
 					if (node.getStatus() == Status.FAILED) {
 						// Retry failure if conditions are met.
 						if (!runner.isCancelled() && runner.getRetries() > node.getAttempt()) {
fix the bug when job finishes the flow not get updated until next job submission