据我所知，没有使用默认bucketingsink添加后缀的选项。
一个选项是不使用检查点，并将挂起的后缀设置为所需的后缀。但由于检查点在大多数情况下都是可取的，所以这并不是最佳的。
我的解决方案是创建一个bucketingsinkwithsuffix实现，它几乎是默认bucketingsink的精确副本。唯一需要更改的是为后缀添加一个成员变量，后缀可以在构造函数中设置，并调整创建基路径的方式。
以下是我对构造函数的实现：

public BucketingSinkWithSuffix(String basePath, String suffix) {
    this.basePath = basePath;
    this.bucketer = new DateTimeBucketer<>();
    this.writerTemplate = new StringWriter<>();
    this.partSuffix = suffix;
}

以及用于生成基本路径（第523和528行）：

partPath = new Path(bucketPath, partPrefix + "-" + subtaskIndex + "-" + bucketState.partCounter + partSuffix);