Hi Andrey, Yes. CustomBucketingSink is custom class copied from Bucketing Sink itself .
Few changes were added : 1. Add timestamp in part files 2. Few Logging statements Note: Looks like I copied it from version 1.4 ( Don't know if that could be the reason for failure) Did it override BucketingSink.onProcessingTime? - It is same as present in original BucketingSink . Attaching Java File .Also added comment : " // Added by Sohi" . You can search and see the changes there I have made . File : CustomBucketingSink.java <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t894/CustomBucketingSink.java> Thanks Sohan -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
