TextFormat.shortDebugString(executorEnv),
TextFormat.shortDebugString(taskEnv));
log.error(errStr);
throw new InvalidRequirementException(errStr);
}
<BUG>TaskInfo updatedTaskInfo = TaskUtils.setTargetConfiguration(taskBuilder.build(), UUID.fromString(configName));
</BUG>
ExecutorInfo updatedExecutorInfo = ExecutorInfo.newBuilder(taskInfo.getExecutor())
.setCommand(getExecutorCmd(config, configName, Integer.valueOf(brokerIdStr), logdir, port))
.setExecutorId(ExecutorID.newBuilder().setValue("").build()) // Set later by ExecutorRequirement

TextFormat.shortDebugString(executorEnv),
TextFormat.shortDebugString(taskEnv));
log.error(errStr);
throw new InvalidRequirementException(errStr);
}
TaskInfo updatedTaskInfo = TaskUtils.setTargetConfiguration(taskBuilder, UUID.fromString(configName)).build();
ExecutorInfo updatedExecutorInfo = ExecutorInfo.newBuilder(taskInfo.getExecutor())
.setCommand(getExecutorCmd(config, configName, Integer.valueOf(brokerIdStr), logdir, port))
.setExecutorId(ExecutorID.newBuilder().setValue("").build()) // Set later by ExecutorRequirement
