Yun Gao created FLINK-27910:
-------------------------------

             Summary: FileSink not registered the timer to enforce rolling 
policy if started from scratch
                 Key: FLINK-27910
                 URL: https://issues.apache.org/jira/browse/FLINK-27910
             Project: Flink
          Issue Type: Bug
          Components: Connectors / FileSystem
    Affects Versions: 1.15.0, 1.16.0
            Reporter: Yun Gao


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. 



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to