Hi,
I am attempting to make use of the new window APIs in streaming to
implement a session based window and am not sure if the currently provided
functionality handles my use case. Specifically what I want to do is
something conceptually similar to a ³Sessions.withGapDuration(Š)² window
in Google
e let us know if you need more information. I’m always happy to help
>in these interesting cases at the bleeding edge of what is possible. :-)
>
>Cheers,
>Aljoscha
>
>> On 16 Oct 2015, at 19:36, Hamilton, Paul
>>wrote:
>>
>> Hi,
>>
>> I am attempt
Hi,
We are trying to rework the way our Flink jobs (and really it becomes how the
operators within the jobs) log. Specifically we are trying to add contextual
information to the log messages so that it is easier to filter and search for a
specific jobs logs after they have been send through to