[Fix] Fix submit to k8s retry and timeout too less. (#3416)

Co-authored-by: Bibo <[email protected]>
apache · Dec 21, 2023 · cd62145 · cd62145
1 parent 500592e
commit cd62145
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala b/...ubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala
@@ -41,11 +41,11 @@ import scala.util.{Failure, Success, Try}
 object KubernetesRetriever extends Logger {
 
   // see org.apache.flink.client.cli.ClientOptions.CLIENT_TIMEOUT}
-  val FLINK_CLIENT_TIMEOUT_SEC = 30L
+  val FLINK_CLIENT_TIMEOUT_SEC = 60L
   // see org.apache.flink.configuration.RestOptions.AWAIT_LEADER_TIMEOUT
-  val FLINK_REST_AWAIT_TIMEOUT_SEC = 10L
+  val FLINK_REST_AWAIT_TIMEOUT_SEC = 30L
   // see org.apache.flink.configuration.RestOptions.RETRY_MAX_ATTEMPTS
-  val FLINK_REST_RETRY_MAX_ATTEMPTS = 2
+  val FLINK_REST_RETRY_MAX_ATTEMPTS = 30
 
   /** get new KubernetesClient */
   @throws(classOf[KubernetesClientException])