increase time in dual running state to 15 minutes (#11)

ElementalCognition · Oct 7, 2022 · 2f8c9ba · 2f8c9ba
1 parent f9428ee
commit 2f8c9ba
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/controller/flinkapplication/flink_state_machine.go b/pkg/controller/flinkapplication/flink_state_machine.go
@@ -1182,7 +1182,7 @@ func (s *FlinkStateMachine) handleDualRunning(ctx context.Context, application *
 	// wait until all vertices have been scheduled and started more than 5 minutes
 	allVerticesStarted := true
 	for _, v := range job.Vertices {
-		allVerticesStarted = allVerticesStarted && (v.Duration > 300000)
+		allVerticesStarted = allVerticesStarted && (v.Duration > 900000)
 		logger.Infof(ctx, "Duration of job %s is %v where job.state is %s", v.Name, v.Duration, string(job.State))
 	}