This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 0e936d271 [Fix] Fix submit to k8s retry and timeout too less. (#3417)
0e936d271 is described below
commit 0e936d2712ec92c87bba7b46fb1e54689c768017
Author: minchowang <[email protected]>
AuthorDate: Sat Dec 23 20:26:19 2023 +0800
[Fix] Fix submit to k8s retry and timeout too less. (#3417)
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 ee67a202d..d10f81b9f 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
@@ -42,11 +42,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])
