You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2020/06/04 03:02:00 UTC

[jira] [Created] (FLINK-18110) Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery

Yun Gao created FLINK-18110:
-------------------------------

             Summary: Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery
                 Key: FLINK-18110
                 URL: https://issues.apache.org/jira/browse/FLINK-18110
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.11.0
            Reporter: Yun Gao
             Fix For: 1.11.0


Current streaming file sink using bucket lifecycle listener to support the global commit of  Hive sink, and the listener sends notification when buckets are created and get inactive. However, after failover,  a bucket may be directly detected to be inactive and deserted directly, in this case the listener should also send the inactive notification.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)