Increase stalled pod timeout (#2084)

deliahu · web-flow · commit ebab5a76869d · 2021-04-12T20:10:40.000-07:00
diff --git a/pkg/operator/resources/asyncapi/api.go b/pkg/operator/resources/asyncapi/api.go
@@ -39,7 +39,7 @@ import (
 )
 
 const (
-	_stalledPodTimeout = 10 * time.Minute
+	_stalledPodTimeout = 15 * time.Minute
 	_tickPeriodMetrics = 10 * time.Second
 )
 
diff --git a/pkg/operator/resources/job/worker_stats.go b/pkg/operator/resources/job/worker_stats.go
@@ -25,7 +25,7 @@ import (
 	kcore "k8s.io/api/core/v1"
 )
 
-const _stalledPodTimeout = 10 * time.Minute
+const _stalledPodTimeout = 15 * time.Minute
 
 func GetWorkerCountsForJob(k8sJob kbatch.Job, pods []kcore.Pod) status.WorkerCounts {
 	if k8sJob.Status.Failed > 0 {
diff --git a/pkg/operator/resources/realtimeapi/status.go b/pkg/operator/resources/realtimeapi/status.go
@@ -31,7 +31,7 @@ import (
 	kcore "k8s.io/api/core/v1"
 )
 
-const _stalledPodTimeout = 10 * time.Minute
+const _stalledPodTimeout = 15 * time.Minute
 
 func GetStatus(apiName string) (*status.Status, error) {
 	var deployment *kapps.Deployment

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ import (`
`39`	`39`	`)`
`40`	`40`
`41`	`41`	`const (`
`42`		`- _stalledPodTimeout = 10 * time.Minute`
	`42`	`+ _stalledPodTimeout = 15 * time.Minute`
`43`	`43`	`_tickPeriodMetrics = 10 * time.Second`
`44`	`44`	`)`
`45`	`45`
Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ import (`
`25`	`25`	`kcore "k8s.io/api/core/v1"`
`26`	`26`	`)`
`27`	`27`
`28`		`-const _stalledPodTimeout = 10 * time.Minute`
	`28`	`+const _stalledPodTimeout = 15 * time.Minute`
`29`	`29`
`30`	`30`	`func GetWorkerCountsForJob(k8sJob kbatch.Job, pods []kcore.Pod) status.WorkerCounts {`
`31`	`31`	`if k8sJob.Status.Failed > 0 {`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ import (`
`31`	`31`	`kcore "k8s.io/api/core/v1"`
`32`	`32`	`)`
`33`	`33`
`34`		`-const _stalledPodTimeout = 10 * time.Minute`
	`34`	`+const _stalledPodTimeout = 15 * time.Minute`
`35`	`35`
`36`	`36`	`func GetStatus(apiName string) (*status.Status, error) {`
`37`	`37`	`var deployment *kapps.Deployment`