Skip to content

Commit

Permalink
[FLINK-25243][k8s] Increase the k8s transactional operation max retri…
Browse files Browse the repository at this point in the history
…es in the integration tests to make the tests more stable

This closes apache#18891.
  • Loading branch information
wangyang0918 authored and gaoyunhaii committed Mar 2, 2022
1 parent 176aaed commit 152ad4f
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@
public class KubernetesResource extends ExternalResource {

private static final String CLUSTER_ID = "flink-itcase-cluster";
private static final int KUBERNETES_TRANSACTIONAL_OPERATION_MAX_RETRIES = 100;

private static String kubeConfigFile;
private Configuration configuration;
Expand All @@ -56,6 +57,9 @@ public void before() {
configuration = new Configuration();
configuration.set(KubernetesConfigOptions.KUBE_CONFIG_FILE, kubeConfigFile);
configuration.setString(KubernetesConfigOptions.CLUSTER_ID, CLUSTER_ID);
configuration.set(
KubernetesConfigOptions.KUBERNETES_TRANSACTIONAL_OPERATION_MAX_RETRIES,
KUBERNETES_TRANSACTIONAL_OPERATION_MAX_RETRIES);
final FlinkKubeClientFactory kubeClientFactory = new FlinkKubeClientFactory();
flinkKubeClient = kubeClientFactory.fromConfiguration(configuration, "testing");
}
Expand Down

0 comments on commit 152ad4f

Please sign in to comment.