Isn't the returns functions deprecated? On Tue, Jul 31, 2018, 5:32 AM vino yang <yanghua1...@gmail.com> wrote:
> Hi Nicos, > > The thrown exception has given you a clear solution hint: > The return type of function 'apply(Mu > ltiplyByTwoTest.scala:43)' could not be determined automatically, due > to type erasure. You can giv > e type information hints by using the returns(...) method on the result > of the transformation call > , or by letting your function implement the 'ResultTypeQueryable' > interface. > > You can consider the second option. More information on the Flink type > system can be found in the official documentation[1]. > > [1]: > https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/types_serialization.html#type-information-in-the-scala-api > > Thanks, vino. > > 2018-07-31 6:30 GMT+08:00 Nicos Maris <nicos.ma...@gmail.com>: > >> Hi all, >> >> >> the integration test in scala documented at the testing section fails: >> >> https://travis-ci.org/nicosmaris/HelloDockerScalaSbt/builds/410075764 >> >> In previous commits of my demo repo, I tried typextractor , basictypeinfo >> and resultTypeQuerable with no success. I am new to flink and to Scala and >> I would like to have both, not flink with Java. >> >> Am I doing something that is fundamentally wrong? >> >> >> thanks, >> Nicos Maris >> > >