Yes. Adding .returns(typeInfo) works as well. :-) 2017-12-08 11:29 GMT+01:00 Fabian Hueske <fhue...@gmail.com>:
> 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 GMT+01:00 Sendoh <unicorn.bana...@gmail.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/HungUnicorn/8a5c40fcf1e25c51cf77dc24a227d6d4 >> >> Best, >> >> Sendoh >> >> >> >> -- >> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4. >> nabble.com/ >> > >
