[FLINK-19166] StreamingFileWriter should register Listener before the initialization of buckets

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.11.1
• Fix Version/s: 1.11.2, 1.12.0
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 09/Sep/20 03:05
• Updated: 09/Sep/20 14:17
• Resolved: 09/Sep/20 14:17

Description

In http://apache-flink.147419.n8.nabble.com/StreamingFileSink-hive-metadata-td6898.html

The feedback of User indicates that some partitions have not been committed since the job failed.

This maybe due to FLINK-18110, in FLINK-18110, it has fixed Buckets, but forgot fixing StreamingFileWriter , it should register Listener before the initialization of buckets, otherwise, will loose listening too.

Issue Links

• links to: GitHub Pull Request #13363