Я хочу пометить объекты s3, созданные с помощью плагина файловой системы s3a для flink 1.10. Конвейер должен определять, как помечать объекты s3, созданные с помощью streamingfilesink. API еще не поддерживает эту функцию, но может быть легко добавлен, например. перегрузка initiateMultiPartUpload InternalWriteOperationHelper из HadoopS3AccessHelper и передача необходимой информации тега в InitiateMultipartUploadRequest с помощью setTagging. Я хочу отправить исправление для этого.
Есть ли какие-либо опасения со стороны сообщества по поводу этой функции?