Thanks Biao, just want to not reinvent the wheel :)
> On Jul 22, 2019, at 4:29 PM, Biao Liu wrote:
>
> Hi Andy,
>
> As far as I know, Flink does not support feature like that.
>
> I would suggest recording and calculating the time in user code.
> For example, add a timestamp field (maybe an
Hi Andy,
As far as I know, Flink does not support feature like that.
I would suggest recording and calculating the time in user code.
For example, add a timestamp field (maybe an array) in your record with
printing a timestamp on in by each processing.
Andy Hoang 于2019年7月22日周一 下午4:49写道：
> Hi
Hi guys,
I’m trying to write elk log for flink, this help us to store/calculate
processing time of a group of operators for business auditing.
I read about process_function and Debugging Windows & Event Time in docs.
They’re focus on “keyed” events and monitoring using web/metric, where I want
