Skip to content

Commit

Permalink
[FLINK-13946] Remove unused constructors from RemoteExecutor
Browse files Browse the repository at this point in the history
  • Loading branch information
kl0u committed Sep 6, 2019
1 parent c746cbb commit 80fa99d
Showing 1 changed file with 0 additions and 31 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@
import org.apache.flink.optimizer.costs.DefaultCostEstimator;
import org.apache.flink.optimizer.plan.OptimizedPlan;
import org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator;
import org.apache.flink.util.NetUtils;

import java.net.InetSocketAddress;
import java.net.URL;
Expand Down Expand Up @@ -66,36 +65,6 @@ public RemoteExecutor(String hostname, int port) {
Collections.<URL>emptyList());
}

public RemoteExecutor(String hostname, int port, URL jarFile) {
this(hostname, port, new Configuration(), Collections.singletonList(jarFile),
Collections.<URL>emptyList());
}

public RemoteExecutor(String hostport, URL jarFile) {
this(NetUtils.parseHostPortAddress(hostport), new Configuration(), Collections.singletonList(jarFile),
Collections.<URL>emptyList());
}

public RemoteExecutor(String hostname, int port, List<URL> jarFiles) {
this(new InetSocketAddress(hostname, port), new Configuration(), jarFiles,
Collections.<URL>emptyList());
}

public RemoteExecutor(String hostname, int port, Configuration clientConfiguration) {
this(hostname, port, clientConfiguration, Collections.<URL>emptyList(),
Collections.<URL>emptyList());
}

public RemoteExecutor(String hostname, int port, Configuration clientConfiguration, URL jarFile) {
this(hostname, port, clientConfiguration, Collections.singletonList(jarFile),
Collections.<URL>emptyList());
}

public RemoteExecutor(String hostport, Configuration clientConfiguration, URL jarFile) {
this(NetUtils.parseHostPortAddress(hostport), clientConfiguration,
Collections.singletonList(jarFile), Collections.<URL>emptyList());
}

public RemoteExecutor(String hostname, int port, Configuration clientConfiguration,
List<URL> jarFiles, List<URL> globalClasspaths) {
this(new InetSocketAddress(hostname, port), clientConfiguration, jarFiles, globalClasspaths);
Expand Down

0 comments on commit 80fa99d

Please sign in to comment.