beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Davor Bonaci (JIRA)" <>
Subject [jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI
Date Mon, 08 May 2017 16:47:04 GMT


Davor Bonaci commented on BEAM-1107:

[~aljoscha], are you on this?

I'm moving the versions tag from 2.0.0 to 2.1.0, but please roll it back if there's a chance
you can do this in the next 1-2 days.

> Display user names for steps in the Flink Web UI
> ------------------------------------------------
>                 Key: BEAM-1107
>                 URL:
>             Project: Beam
>          Issue Type: Improvement
>          Components: runner-flink
>            Reporter: Daniel Halperin
>            Assignee: Aljoscha Krettek
>             Fix For: 2.0.0
>         Attachments: screenshot-1.png
> [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:
> Before this change, the "ReadLines" step showed up as: "DataSource (at Read(CompressedSource)
> 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]
> [2]

This message was sent by Atlassian JIRA

View raw message