Hi Ido,
thank you for your good example to reproduce the problem. I could find a
bug in Flink's type extraction logic and opened an issue for it [0]. The
problem seems to be the bounded generics in both the Foo and FooFoo.
Foo.someKey has the wrong type information. It is
GenericType.
As a
Hi Ido,
at the first glance, I could not find any problem in your code. So it
might be a bug. The "environment.registerType()" is not needed in your
case, because you have no generic types.
I will have a closer look at it tomorrow.
Regards,
Timo
Am 14.08.17 um 16:35 schrieb Ido Bar Av:
Hi
