0
У нас есть некоторые функции, которые обрабатывают элементы из пакета в партиях. Им нужно вывести последнюю партию в методе finishBundle().Почему DoFnTester не поддерживает выходные данные в finishBundle()?
Что-то вроде описанного в ответе this previous question.
В последней версии Dataflow 2.0.0-beta1, основанной на Beam 0.4.0, DoFnTester выбрасывает UnsupportedOperationException из метода finishBundle(), если тестируемая функция вызывает метод вывода в контексте.
Есть ли причины для этого изменения? Вывод из DoFn.finishBundle() больше не поддерживается во время выполнения?
Благодарим за помощь, Даниэль. –
Фактически, он никогда не работал должным образом, за исключением данных, полученных в глобальном масштабе. –