Если файлы .pending были в списке контрольных точек, вам просто нужно перезапустить задание, тогда .pending будет переименовано в окончательное имя для фиксации.Если файлов .pending не было в списке контрольных точек, то есть файлы .pending могут быть отброшены, Flink не будет ничего с ним делать, игнорировать их - хорошая идея.
Попробуйте прочитать В этом блоге , затем читая исходный код BucketingSink , вы узнаете, почему и как это сделать.