Hi,Kartik FileSink does not expose the file name to the user now. Would you like to share your scenario ,which needs the file name?
Best, Guowei 发自我的iPhone > 在 2022年1月30日,下午6:38,Kartik Khare <kharekar...@gmail.com> 写道: > > Hi, > For my use case, I want to get the part file name that is being created in > the HDFS when using the file sink. I saw the code and can’t find a way to > extend one of the existing Bucket classes to achieve this. The thing I am > looking for is `assemblePartFilePath` functions output. > > Regards, > Kartik