Hi, We are using StreamingFileSink with a custom BucketAssigner and DefaultRollingPolicy. The custom BucketAssigner is simply a date bucket assigner. The StreamingFileSink creates part files with name "part-<subtask_number>-<count_of_the_bucket_created_by_that_subtask>". The count is an integer and is incrementing on each rollover. Now my doubts are:
1. When does this count reset to 0 ? 2. Is there a way i can reset this count programmatically ? Since we are using day bucket we would like the count to reset every day. We are using Flink 1.8 Thanks Sidhartha
