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

StreamingFileWriter should register Listener before the initialization of buckets

    XMLWordPrintableJSON

    Details

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                lzljs3620320 Jingsong Lee
                Reporter:
                lzljs3620320 Jingsong Lee
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: