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/ >
