[BEAM-1107] Display user names for steps in the Flink Web UI

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Duplicate
• Fix Version/s: 2.5.0
• Component/s: runner-flink
• Assignee: Aljoscha Krettek
• Reporter: Dan Halperin
• Created: 07/Dec/16 22:57
• Updated: 16/May/20 13:56
• Resolved: 15/Mar/18 14:31

Description

[copying in-person / email discussion at Strata Singapore to JIRA]

The FlinkBatchTransformTranslators use transform.getName() [1] – this is the "SDK name" for the transform.

The "user name" for the transform is not available here, it is in fact on the TransformHierarchy.Node as node.getFullName() [2].

getFullName() is used some in Flink, but not when setting step names.

I drafted a quick commit that sort of propagates the user names to the web UI (but only for DataSource, and still too verbose: https://github.com/dhalperi/incubator-beam/commit/a2f1fb06b22a85ec738e4f2a604c9a129891916c)

Before this change, the "ReadLines" step showed up as: "DataSource (at Read(CompressedSource) (org.apache.beam.runners.flink.translation.wrappers.SourceInputFormat))"

With this change, it shows up as "DataSource (at ReadLines/Read (org.apache.beam.runners.flink.translation.wrappers.SourceInputFormat))"

which I think is closer. [I'd still like it to JUST be "ReadLines/Read" e.g.].

Thoughts?

[1] https://github.com/apache/incubator-beam/blob/master/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java#L129
[2] https://github.com/apache/incubator-beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java#L252

Issue Links

• is duplicated by: BEAM-3281 PTransform name not being propagated to the Flink Web UI
• relates to: BEAM-3043 Set user-specified Transform names on Flink operations