Load configuration manager for Presto-on-Spark driver
Presto-on-Spark executor doesn't need this component.
@@ -42,6 +42,7 @@ import java.util.Map.Entry;
import java.util.Optional;
import static com.facebook.presto.server.PrestoSystemRequirements.verifySystemTimeIsReasonable;
+import static com.facebook.presto.spark.classloader_interface.SparkProcessType.DRIVER;
import static com.google.common.collect.ImmutableMap.toImmutableMap;
import static java.util.Objects.requireNonNull;
@@ -156,6 +157,7 @@ public class PrestoSparkInjectorFactory
injector.getInstance(AccessControlManager.class).loadSystemAccessControl();
}
}
+ if ((sparkProcessType.equals(DRIVER))) {
if (sessionPropertyConfigurationProperties.isPresent()) {
injector.getInstance(SessionPropertyDefaults.class).loadConfigurationManager(sessionPropertyConfigurationProperties.get());
}
@@ -163,6 +165,7 @@ public class PrestoSparkInjectorFactory
injector.getInstance(SessionPropertyDefaults.class).loadConfigurationManager();
}
}
+ }
catch (Exception e) {
throw new RuntimeException(e);
}
