Я использую JDK 17 и Apache Beam 2.50, и на графике потока данных gcp и при чтении из Avro/записи в BigQuery я получаю
ЧИТАТЬ СООБЩЕНИЯ RAW+ ИЗ AVRO файла/Read.out0
Добавлено элементов: 332
Ориентировочный размер: 27,37 МБ
После обновления луча до 2.54/2.55.1 я ничего не получаю оценки, но файлы нормально читаются/записываются.
ЧИТАТЬ СООБЩЕНИЯ RAW+ ОТ AVRO file/Read/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper).out0
Добавлены элементы: –
Оценено размер: –
Код на моей стороне тот же, но не знаю, где именно искать.
Надеюсь, получить то же самое на графике заданий потока данных, чтобы быть уверенным, что что-то выйдет из строя или не будет работать должным образом, чтобы иметь представление.
Подробнее здесь: https://stackoverflow.com/questions/788 ... ow-gcp-don
