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
Hi,
We're using flink 1.3.1, and we're trying to pass through the pipeline a POJO
object that has a generic field )see details in the complete example below):
We have the class Foo, and when sending a subclass with
a specific SomeKey, we get the following exception:
java.lang.RuntimeException:
