Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5312#discussion_r164074605
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClientConfiguration.java
---
@@ -19,60 +19,73 @@
package org.apache.flink.client.program.rest;
import org.apache.flink.configuration.Configuration;
-import org.apache.flink.configuration.JobManagerOptions;
import org.apache.flink.configuration.RestOptions;
import org.apache.flink.runtime.rest.RestClientConfiguration;
import org.apache.flink.util.ConfigurationException;
import org.apache.flink.util.Preconditions;
+import static org.apache.flink.util.Preconditions.checkArgument;
+
/**
* A configuration object for {@link RestClusterClient}s.
*/
public final class RestClusterClientConfiguration {
- private final String blobServerAddress;
-
private final RestClientConfiguration restClientConfiguration;
- private final String restServerAddress;
+ private final int awaitLeaderTimeout;
+
+ private final int retryMaxAttempts;
- private final int restServerPort;
+ private final int retryDelay;
private RestClusterClientConfiguration(
- String blobServerAddress,
- RestClientConfiguration endpointConfiguration,
- String restServerAddress,
- int restServerPort) {
- this.blobServerAddress =
Preconditions.checkNotNull(blobServerAddress);
+ final RestClientConfiguration endpointConfiguration,
+ final int awaitLeaderTimeout,
+ final int retryMaxAttempts,
+ final int retryDelay) {
--- End diff --
changed all delays and timeouts to `long`
---
