[hotfix] Harden SlotPoolRcpTest#testCancelSlotAllocationWithoutResourceManager

上级 ec752138
......@@ -361,11 +361,13 @@ public class SlotPoolRpcTest extends TestLogger {
@Nullable Throwable cause) {
final Consumer<SlotRequestId> currentReleaseSlotConsumer = releaseSlotConsumer;
final CompletableFuture<Acknowledge> acknowledgeCompletableFuture = super.releaseSlot(slotRequestId, slotSharingGroupId, cause);
if (currentReleaseSlotConsumer != null) {
currentReleaseSlotConsumer.accept(slotRequestId);
}
return super.releaseSlot(slotRequestId, slotSharingGroupId, cause);
return acknowledgeCompletableFuture;
}
CompletableFuture<Boolean> containsAllocatedSlot(AllocationID allocationId) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册