docs: @Override
  	public void declineCheckpoint(DeclineCheckpoint decline) {
  		final CheckpointCoordinator checkpointCoordinator = executionGraph.getCheckpointCoordinator();
  
  		if (checkpointCoordinator != null) {
  			getRpcService().execute(() -> {
  				try {
  					checkpointCoordinator.receiveDeclineMessage(decline);
  				} catch (Exception e) {
  					log.error("Error in CheckpointCoordinator while processing {}", decline, e);
  				}
  			});
  		} else {
  			String errorMessage = "Received DeclineCheckpoint message for job {} with no CheckpointCoordinator";
  			if (executionGraph.getState() == JobStatus.RUNNING) {
  				log.error(errorMessage, jobGraph.getJobID());
  			} else {
  				log.debug(errorMessage, jobGraph.getJobID());
  			}
  		}
  	}