Github user zhangxinyu1 commented on the issue: https://github.com/apache/flink/pull/6108 @kl0u Thanks. Would you please consider to implement a BucketingSource which we can use it to read data from FileSystems? Besides we also care about the limit of bandwidth.
---