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 >
