This is an automated email from the ASF dual-hosted git repository.
linying pushed a commit to branch release-2.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/release-2.1.2 by this push:
new cd62145cd [Fix] Fix submit to k8s retry and timeout too less. (#3416)
cd62145cd is described below
commit cd62145cd2b08b9c6c36af4615962008a584653a
Author: minchowang <[email protected]>
AuthorDate: Thu Dec 21 11:25:07 2023 +0800
[Fix] Fix submit to k8s retry and timeout too less. (#3416)
Co-authored-by: Bibo <[email protected]>
---
.../apache/streampark/flink/kubernetes/KubernetesRetriever.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala
index 17a5df525..413fad4cc 100644
---
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/KubernetesRetriever.scala
+++
b/streampark-flink/streampark-flink-kubernetes/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])
