Hi Timo, This is my case class: /case class Box[T](meta: Metadata, value: T) { def function1: A=>B = {...} def method2(...):A = {...} }/
However, I still get that warning "/Class class data.package$Box cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance./" I imported /org.apache.flink.streaming.api.scala._/ << is this enough to tell that I am using Scala API? Thanks and regards, Averell -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/