Hi Stephan,
I faced the similar issue, the way implemented this(though a workaround) is
by making the input to fold function i.e. the initial value to fold
symmetric to what goes into the window function.
I made the initial value to fold function a tuple with all non
required/available index valu
Hi,
this is a known bug: https://issues.apache.org/jira/browse/FLINK-3869.
I'm still hoping that we can get a workaround in for Flink 1.2. See my last
comment in the Jira Issue.
Cheers,
Aljoscha
On Mon, 14 Nov 2016 at 14:49 Stephan Epping
wrote:
> Hello,
>
> I wondered if there is a particular
