.setTaskId(TaskID.newBuilder().setValue("").build()) // Set later by TaskRequirement
.build();
ExecutorInfo replaceExecutorInfo = ExecutorInfo.newBuilder(existingTaskInfo.getExecutor())
.setExecutorId(ExecutorID.newBuilder().setValue("").build()) // Set later by ExecutorRequirement
.build();
<BUG>OfferRequirement offerRequirement = new OfferRequirement(
</BUG>
BROKER_TASK_TYPE,
Arrays.asList(replaceTaskInfo),
<BUG>Optional.of(replaceExecutorInfo));

log.info(String.format("Got replacement OfferRequirement: TaskInfo: '%s' ExecutorInfo: '%s'",</BUG>
TextFormat.shortDebugString(replaceTaskInfo),

.setTaskId(TaskID.newBuilder().setValue("").build()) // Set later by TaskRequirement
.build();
ExecutorInfo replaceExecutorInfo = ExecutorInfo.newBuilder(existingTaskInfo.getExecutor())
.setExecutorId(ExecutorID.newBuilder().setValue("").build()) // Set later by ExecutorRequirement
.build();
OfferRequirement offerRequirement = OfferRequirement.create(
BROKER_TASK_TYPE,
Arrays.asList(replaceTaskInfo),
Optional.of(replaceExecutorInfo),
Optional.empty());
log.info(String.format("Got replacement OfferRequirement: TaskInfo: '%s' ExecutorInfo: '%s'",
TextFormat.shortDebugString(replaceTaskInfo),
