Github user zhangxinyu1 commented on the issue: https://github.com/apache/flink/pull/6108 @StephanEwen Thanks for your reply. BTW, is their any issue about BucketingSink rewriting? We also want to use the BucketingSink which supports for parquet and orc.
---