0

我们有一些函数可以批量处理捆绑包中的元素。他们需要在 finishBundle() 方法中输出最后一批。

类似于上一个问题的答案中描述的内容。

在基于 Beam 0.4.0 的最新 Dataflow 2.0.0-beta1 版本中，如果被测函数在上下文中调用输出方法，则 DoFnTester 会从其 finishBundle() 方法中抛出 UnsupportedOperationException。

这种行为改变有什么原因吗？运行时不再支持 DoFn.finishBundle() 的输出吗？

4

1 回答 1

0

这是 DoFnTester 中的回归。我在这里提交了一个针对 Beam 的错误

于 2017-01-19T18:50:38.490 回答