You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/09/07 18:39:31 UTC
[22/36] beam git commit: mr-runner: use the correct step name in
ParDoTranslator, this fixes MetricsTest.testAttemptedCounterMetrics().
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 <pe...@apache.org>
Authored: Thu Aug 31 19:25:10 2017 +0800
Committer: Pei He <pe...@apache.org>
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(),