docs: @Override
  	public void notifyCheckpointComplete(long checkpointId) throws Exception {
  		super.notifyCheckpointComplete(checkpointId);
  
  		if (userFunction instanceof CheckpointListener) {
  			((CheckpointListener) userFunction).notifyCheckpointComplete(checkpointId);
  		}
  	}