mr-runner: use the correct step name in ParDoTranslator, this fixes MetricsTest.testAttemptedCounterMetrics().
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0b371875 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0b371875 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0b371875 Branch: refs/heads/mr-runner Commit: 0b3718756b6c22a9cb58dbdf4a3bc8b41cca3d1c Parents: 2d8b12a Author: Pei He <[email protected]> Authored: Thu Aug 31 19:25:10 2017 +0800 Committer: Pei He <[email protected]> Committed: Fri Sep 1 17:13:40 2017 +0800 ---------------------------------------------------------------------- .../apache/beam/runners/mapreduce/translation/ParDoTranslator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/0b371875/runners/map-reduce/src/main/java/org/apache/beam/runners/mapreduce/translation/ParDoTranslator.java ---------------------------------------------------------------------- diff --git a/runners/map-reduce/src/main/java/org/apache/beam/runners/mapreduce/translation/ParDoTranslator.java b/runners/map-reduce/src/main/java/org/apache/beam/runners/mapreduce/translation/ParDoTranslator.java index e866fe2..f8f1a02 100644 --- a/runners/map-reduce/src/main/java/org/apache/beam/runners/mapreduce/translation/ParDoTranslator.java +++ b/runners/map-reduce/src/main/java/org/apache/beam/runners/mapreduce/translation/ParDoTranslator.java @@ -31,7 +31,7 @@ class ParDoTranslator<InputT, OutputT> ParDo.MultiOutput<InputT, OutputT> transform, TranslationContext context) { TranslationContext.UserGraphContext userGraphContext = context.getUserGraphContext(); NormalParDoOperation operation = new NormalParDoOperation( - transform.getName(), + userGraphContext.getStepName(), transform.getFn(), userGraphContext.getOptions(), transform.getMainOutputTag(),
