CompletableFuture<String> getOperationFuture() {
        return operationFuture;
    }
@Test
    void testExceptionalSavepointCompletionLeadsToExceptionalOperationFutureCompletion()
            throws Exception {
        final StopWithSavepoint sws;
        try (MockStopWithSavepointContext ctx = new MockStopWithSavepointContext()) {
            CheckpointScheduling mockStopWithSavepointOperations = new MockCheckpointScheduling();
            CompletableFuture<String> savepointFuture = new CompletableFuture<>();
            sws = createStopWithSavepoint(ctx, mockStopWithSavepointOperations, savepointFuture);
            ctx.setStopWithSavepoint(sws);
            ctx.setExpectExecuting(assertNonNull());

            savepointFuture.completeExceptionally(new RuntimeException("Test error"));
        }
        assertThat(sws.getOperationFuture()).isCompletedExceptionally();
    }