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)
