Hi Fabian,
Thank you for the quick reply and for looking into it.
Sorry, I was a bit too quick with the field reference accusation. Turns
out, my TypeInformation was wrong, hence the invalid reference exception.
However, the type erasure problem still holds.
The actual code can be found here
Hi Martin,
thanks for reporting the problem and providing code to reproduce it.
Would you mind to describe the problem with the forwarding annotations in
more detail?
I would be interested in the error message and how the semantic annotation
is provided (@ForwardFields or withForwardedFields()).
Hi,
I am running into a type erasure problem which only occurs when I
execute the code using a Flink cluster (1.1.2). I created a Gist [1]
which reproduces the problem. I also added a unit test to show that it
does not fail in local and collection mode.
Maybe it is also interesting to mentio
