Streaming File Sink cannot generate _SUCCESS tag files

[highfei2011]

Hi, everyone!
      Currently experiencing a problem with the bucketing policy sink to hdfs 
using BucketAssigner of Streaming File Sink after consuming Kafka data with 
FLink -1.11.2, the _SUCCESS tag file is not generated by default.
      I have added the following to the configuration 


val hadoopConf = new Configuration()
hadoopConf.set(FileOutputCommitter.SUCCESSFUL_JOB_OUTPUT_DIR_MARKER, "true")    


But there is still no _SUCCESS file in the output directory, so why not support 
generating _SUCCESS files?


Thank you.




Best,
Yang