Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-1670

LocalState#get(String) can throw FileNotFoundException which results in not removing worker heartbeats and supervisor is kind of stuck and goes down after some time.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • 1.0.0, 2.0.0
    • 1.0.0, 2.0.0
    • storm-core
    • None

    Description

      LocalState#get(String) can throw FileNotFoundException which may result in supervisor.clj#sync-processes which stop assigning new workers/assignments etc and supervisor goes down later.

      VersionedStore#mostRecentVersionPath() can return a file only with suffix of .version but the original file for a specific version may not have been there because .version suffix was not deleted but respective data file may have been deleted in earlier cleanups.

      Attachments

        Activity

          People

            satish.duggana Satish Duggana
            satish.duggana Satish Duggana
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: