Thanks! don't know this works as well.
Cheers,
Sendoh
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Yes.
Adding .returns(typeInfo) works as well. :-)
2017-12-08 11:29 GMT+01:00 Fabian Hueske :
> Hi,
>
> you give the TypeInformation to your user code but you don't expose it to
> the DataStream API (the code of the FlatMapFunction is a black box for the
> API).
> You're FlatMapFunction should imp
Hi,
you give the TypeInformation to your user code but you don't expose it to
the DataStream API (the code of the FlatMapFunction is a black box for the
API).
You're FlatMapFunction should implement the ResultTypeQueryable interface
and return the TypeInformation.
Best, Fabian
2017-12-08 11:19 G
Found it. I should use .returns(typeInformation) after the map function.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Flink users,
I found the workarounds to resolve this exception in scala.
https://issues.apache.org/jira/browse/FLINK-6500
But I already provide the TypeInformation when deserializing json object,
and still see this exception.
Is there anything I ignore?
The sample code
https://gist.github.com
