Skip to content
Permalink
Browse files
[3846] Refactoring of the Kubernetes shim (#3847)
  • Loading branch information
surahman committed Jul 24, 2022
1 parent 12b8abc commit 41e098862f5d10a39738fe5e1139649d1c47c151
Show file tree
Hide file tree
Showing 10 changed files with 1,272 additions and 934 deletions.
@@ -219,7 +219,7 @@ public static boolean getVolumesFromCLIDisabled(Config config) {
@VisibleForTesting
protected static Map<String, Map<KubernetesConstants.VolumeConfigKeys, String>>
getVolumeConfigs(final Config config, final String prefix, final boolean isExecutor) {
final Logger LOG = Logger.getLogger(V1Controller.class.getName());
final Logger LOG = Logger.getLogger(KubernetesShim.class.getName());

final String prefixKey = String.format(prefix,
isExecutor ? KubernetesConstants.EXECUTOR_NAME : KubernetesConstants.MANAGER_NAME);
@@ -50,7 +50,7 @@ public class KubernetesScheduler implements IScheduler, IScalable {
private UpdateTopologyManager updateTopologyManager;

protected KubernetesController getController() {
return new V1Controller(configuration, runtimeConfiguration);
return new KubernetesShim(configuration, runtimeConfiguration);
}

@Override

0 comments on commit 41e0988

Please sign in to comment.