.addResources(DynamicPortRequirement.getDesiredDynamicPort("API_PORT", role, principal))
.build();
log.info(String.format("Got new OfferRequirement: TaskInfo: '%s' ExecutorInfo: '%s'",
TextFormat.shortDebugString(taskInfo),
TextFormat.shortDebugString(executorInfo)));
<BUG>return new OfferRequirement(
</BUG>
BROKER_TASK_TYPE,
Arrays.asList(taskInfo),
Optional.of(executorInfo),

.addResources(DynamicPortRequirement.getDesiredDynamicPort("API_PORT", role, principal))
.build();
log.info(String.format("Got new OfferRequirement: TaskInfo: '%s' ExecutorInfo: '%s'",
TextFormat.shortDebugString(taskInfo),
TextFormat.shortDebugString(executorInfo)));
return OfferRequirement.create(
BROKER_TASK_TYPE,
Arrays.asList(taskInfo),
Optional.of(executorInfo),
