fix(launcher): 修复空值环境变量错误
This commit is contained in:
@@ -174,6 +174,11 @@ public class ExecutorService {
|
||||
}
|
||||
|
||||
private void setEnvironment(Configuration configuration, String key, String value) {
|
||||
logger.info("Setting environment variable {} = {}", key, value);
|
||||
if (ObjectUtil.isNull(value)) {
|
||||
logger.warn("Environment variable {} is null", key);
|
||||
return;
|
||||
}
|
||||
configuration.setString(ResourceManagerOptions.CONTAINERIZED_MASTER_ENV_PREFIX + key, value);
|
||||
configuration.setString(ResourceManagerOptions.CONTAINERIZED_TASK_MANAGER_ENV_PREFIX + key, value);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user