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)