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
> (bartvandee...@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
>>
