@Override
    public void cancel(ExecutionAttemptID executionAttemptId) {
        final CompletableFuture<LogicalSlot> slotFuture =
                this.requestedPhysicalSlots.getValueByKeyA(executionAttemptId);
        if (slotFuture != null) {
            slotFuture.cancel(false);
        }
    }
@Test
    void testCompletedLogicalSlotCancellationDoesNotCancelPhysicalSlotRequest() throws Exception {
        testLogicalSlotRequestCancellationOrRelease(
                true,
                false,
                (context, slotFuture) -> {
                    context.getAllocator().cancel(EXECUTION_ATTEMPT_ID);
                    slotFuture.get();
                });
    }