2017-01-19 7 views
0

バンドルの要素をバッチで処理する関数がいくつかあります。 finishBundle()メソッドで最後のバッチを出力する必要があります。なぜDoFnTesterはfinishBundle()の出力をサポートしていませんか?

this previous questionの答えに記述されているようなものです。

Beam 0.4.0に基づく最新のDataflow 2.0.0-beta1リリースでは、テスト対象の関数がそこのコンテキストで出力メソッドを呼び出すと、DoFnTesterはfinishBundle()メソッドからUnsupportedOperationExceptionをスローします。

この動作が変更される理由はありますか?実行時にDoFn.finishBundle()からの出力はサポートされなくなりましたか?

答えて

0

これはDoFnTesterの回帰です。私はBeamにバグを提出しましたhere

+0

ダニエル、ありがとうございました。 –

+0

実際には、グローバルにウィンドウ化されたテストデータを除いて、正常に動作しませんでした。 –

関連する問題