Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6320

Flakey JobManagerHAJobGraphRecoveryITCase

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 1.3.0
    • 1.3.1, 1.4.0
    • Tests

    Description

      it looks as if there is a race condition in the cleanup of JobManagerHAJobGraphRecoveryITCase.

      Tests run: 2, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 50.271 sec <<< FAILURE! - in org.apache.flink.test.recovery.JobManagerHAJobGraphRecoveryITCase
      testJobPersistencyWhenJobManagerShutdown(org.apache.flink.test.recovery.JobManagerHAJobGraphRecoveryITCase)  Time elapsed: 0.129 sec  <<< ERROR!
      java.io.FileNotFoundException: File does not exist: /tmp/9b63934b-789d-428c-aa9e-47d5d8fa1e32/recovery/submittedJobGraphf763d61fba47
      	at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:2275)
      	at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1653)
      	at org.apache.commons.io.FileUtils.deleteDirectory(FileUtils.java:1535)
      	at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:2270)
      	at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1653)
      	at org.apache.flink.test.recovery.JobManagerHAJobGraphRecoveryITCase.cleanUp(JobManagerHAJobGraphRecoveryITCase.java:112)
      

      Full log: https://s3.amazonaws.com/archive.travis-ci.org/jobs/223124016/log.txt

      Maybe a rule-based temporary directory is a better solution:

      	@Rule
      	public TemporaryFolder tempFolder = new TemporaryFolder();
      

      Attachments

        Issue Links

          Activity

            People

              nkruber Nico Kruber
              nkruber Nico Kruber
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: