You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Bart van Deenen <ba...@fastmail.fm> on 2016/09/12 07:44:48 UTC

setting the name of a subtask ?

Hi all

I'm using Flink 1.1 with a streaming job, consisting of a few maps and a
few aggregations.
In the web dashboard for the job I see subtask names like:

TriggerWindow(SlidingEventTimeWindows(600000, 5000),
FoldingStateDescriptor{serializer=null, initialValue=Res(0,List()),
foldFunction=org.apache.flink.streaming.api.scala.function.util.ScalaFoldFunction@5c42d2b7},
EventTimeTrigger(), WindowedStream.fold(WindowedStream.java:238)) ->
Filter -> Map        

Is it possible to give this a more human readable name from my job
program? 

Greetings

Bart van Deenen

Re: setting the name of a subtask ?

Posted by Bart van Deenen <ba...@fastmail.fm>.

Thanks!


On Mon, Sep 12, 2016, at 10:18, Tzu-Li (Gordon) Tai wrote:
> Hi!
>
> Yes, you can set custom operator names by calling `.name(…)` on
> DataStreams after a transformation.
> For example, `.addSource(…).map(...).name(…)`. This name will be used
> for visualization on the dashboard, and also for logging.
>
> Regards,
> Gordon
>
>
>
> On September 12, 2016 at 3:44:58 PM, Bart van Deenen
> (bartvandeenen@fastmail.fm) wrote:
>>
>>
>> Hi all
>>
>> I'm using Flink 1.1 with a streaming job, consisting of a few maps
>> and a few aggregations. In the web dashboard for the job I see
>> subtask names like:
>>
>> TriggerWindow(SlidingEventTimeWindows(600000, 5000),
>> FoldingStateDescriptor{serializer=null, initialValue=Res(0,List()),
>> foldFunction=org.apache.flink.streaming.api.scala.function.util.Scal-
>> aFoldFunction@5c42d2b7}, EventTimeTrigger(),
>> WindowedStream.fold(WindowedStream.java:238)) -> Filter -> Map
>>
>> Is it possible to give this a more human readable name from my job
>> program?
>>
>> Greetings
>>
>> Bart van Deenen
>>

Re: setting the name of a subtask ?

Posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org>.

Hi!

Yes, you can set custom operator names by calling `.name(…)` on DataStreams after a transformation.
For example, `.addSource(…).map(...).name(…)`. This name will be used for visualization on the dashboard, and also for logging.

Regards,
Gordon


On September 12, 2016 at 3:44:58 PM, Bart van Deenen (bartvandeenen@fastmail.fm) wrote:

Hi all  

I'm using Flink 1.1 with a streaming job, consisting of a few maps and a  
few aggregations.  
In the web dashboard for the job I see subtask names like:  

TriggerWindow(SlidingEventTimeWindows(600000, 5000),  
FoldingStateDescriptor{serializer=null, initialValue=Res(0,List()),  
foldFunction=org.apache.flink.streaming.api.scala.function.util.ScalaFoldFunction@5c42d2b7},  
EventTimeTrigger(), WindowedStream.fold(WindowedStream.java:238)) ->  
Filter -> Map  

Is it possible to give this a more human readable name from my job  
program?  

Greetings  

Bart van Deenen