Change the value of httpGetTimeOut in Flink Client

[aburlutskiy]

flinkk8soperator/pkg/controller/flink/client/api.go

Line 39 in b5eb196

const httpGetTimeOut = 5 * time.Second

It looks like the submitting of our application takes more time rather than 5 seconds. it's cause to loop the submitting process and eventually to fail it.

The output of flink operator looks like the following:

"ClusterStarting:Handling state for application"
"ClusterStarting:Flink cluster has started successfully"
"Savepointing:Handling state for application"
"SubmittingJob:Handling state for application"
"SubmittingJob:No job found for the application"
"SubmittingJob:Logged Warning event: JobSubmissionFailed: Failed to submit job to cluster for deploy 4e1550d8: SubmitJob call failed with status FAILED and message '': Post http://jobmanager:8081/jars/job.jar/run: net/http: request canceled (Client.Timeout exceeded while awaiting headers)"
"SubmittingJob:Conflict while updating status"
"SubmittingJob:Failed to reconcile resource application: Operation cannot be fulfilled on flinkapplications.flink.k8s.io \"application\": the object has been modified; please apply your changes to the latest version and try again"
"SubmittingJob:Handling state for application"
"SubmittingJob:No job found for the application"
"SubmittingJob:Logged Warning event: JobSubmissionFailed: Failed to submit job to cluster for deploy 4e1550d8: SubmitJob call failed with status FAILED and message '': Post http://jobmanager:8081/jars/job.jar/run: net/http: request canceled (Client.Timeout exceeded while awaiting headers)"
"SubmittingJob:Failed to reconcile resource application: SubmitJob call failed with status FAILED and message '': Post http://jobmanager:8081/jars/job.jar/run: net/http: request canceled (Client.Timeout exceeded while awaiting headers)"
"SubmittingJob:Handling state for application"
"SubmittingJob:Conflict while updating status"
"SubmittingJob:Failed to reconcile resource application: Operation cannot be fulfilled on flinkapplications.flink.k8s.io \"application\": the object has been modified; please apply your changes to the latest version and try again"
"SubmittingJob:Handling state for application"
"SubmittingJob:Failed to reconcile resource application: found multiple active jobs for application"
"SubmittingJob:Handle state skipped for application, lastSeenError UnknownMethod call failed with status FAILED and message '': found multiple active jobs for application"