Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8289

Failing the job when the temporary file is accidentally deleted by another job in FileBasedSink

Details

    • Bug
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • io-java-files
    • None

    Description

      There was an issue that a temporary directory name is not unique in FileBasedSink (https://issues.apache.org/jira/browse/BEAM-7689) and we've changed the naming algorithm from timestamp to UUID. However, it looks like UUID is still not enough to distinguish two separate temporary directories from different jobs. We may need to fail the job when the temporary file is accidentally deleted by another job.

      Attachments

        Activity

          People

            Unassigned Unassigned
            heejong Heejong Lee
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: