code: private void clearRunLocks() {
          jobMetaService.runningJobs().forEach((RunningJob runningJob) -> {
              final Optional<JobInfo> jobInfoOptional = jobRepository.findOne(runningJob.jobId);
              if (jobInfoOptional.isPresent() && jobInfoOptional.get().isStopped()) {
                  jobMetaService.releaseRunLock(runningJob.jobType);
                  LOG.error("Clear Lock of Job {}. Job stopped already.", runningJob.jobType);
              } else if (!jobInfoOptional.isPresent()){
                  jobMetaService.releaseRunLock(runningJob.jobType);
                  LOG.error("Clear Lock of Job {}. JobID does not exist", runningJob.jobType);
              }
          });
      }
docs: Checks all run locks and releases the lock, if the job is stopped.
  
  TODO: This method should never do something, otherwise the is a bug in the lock handling.
  TODO: Check Log files + Remove