code: public void release() throws IOException {
      lockFileStream.close();
      if(!fs.delete(lockFile, false)) {
        LOG.warn("Unable to delete lock file, Spout = {}", componentID);
        throw new IOException("Unable to delete lock file");
      }
      LOG.debug("Released lock file {}. Spout {}", lockFile, componentID);
    }
docs: Release lock by deleting file
  @throws IOException if lock file could not be deleted