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

FileSink not enforcing rolling policy if started from scratch

    XMLWordPrintableJSON

Details

    Description

      The current FileWriter only register the timer in initializeState, which is now only called on restoring. Thus if the job is started from scratch, the timer would fail to be registered and cause the rolling policy not work. 

      Attachments

        Issue Links

          Activity

            People

              pltbkd Gen Luo
              gaoyunhaii Yun Gao
              Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: