アグリゲーターステージが間違った行数を出力しています

Question

私はシーケンシャルファイルの行数をとる次のジョブを持っています。たとえば、複数のノードで実行している場合、4つの異なる行数が取得されています。どのように私は行のカウントと1つの行を出力するつもりです。

ソース - >トランス（これはカウントのためにダミー行を有する） - >アグリゲータステージ - >シーケンシャル・ファイル

任意の助けを大幅に高く評価されるだろう！ありがとう！

Answer 1

アグリゲータステージ（ステージアドバンスタブ）の実行モードをシーケンシャルに設定できます。ジョブが大量のデータを処理していない場合、パフォーマンスが低下することはほとんどありません。大きなボリュームを処理する場合は、アグリゲータをParallelのままにしてから別のアグリゲータを追加し、THATをシーケンシャルに設定するのが適切です。