ExecutorInfo updatedExecutorInfo = ExecutorInfo.newBuilder(taskInfo.getExecutor())
.setCommand(getExecutorCmd(config, configName, Integer.valueOf(brokerIdStr), logdir, port))
.setExecutorId(ExecutorID.newBuilder().setValue("").build()) // Set later by ExecutorRequirement
.build();
try {
<BUG>OfferRequirement offerRequirement = new OfferRequirement(
</BUG>
BROKER_TASK_TYPE,
Arrays.asList(updatedTaskInfo),
Optional.of(updatedExecutorInfo));

ExecutorInfo updatedExecutorInfo = ExecutorInfo.newBuilder(taskInfo.getExecutor())
.setCommand(getExecutorCmd(config, configName, Integer.valueOf(brokerIdStr), logdir, port))
.setExecutorId(ExecutorID.newBuilder().setValue("").build()) // Set later by ExecutorRequirement
.build();
try {
OfferRequirement offerRequirement = OfferRequirement.create(
BROKER_TASK_TYPE,
Arrays.asList(updatedTaskInfo),
Optional.of(updatedExecutorInfo));
