Yes, the import was missing thank you for the hint! Now I'm getting the following error:
java.io.IOException: java.lang.NoSuchMethodError: org.apache.flink.util.ClassUtils.isPrimitiveOrBoxedOrString(Ljava/lang/Class;)Z
at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:428)
at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:949)
On 10.02.2015 10:19, Aljoscha Krettek wrote:
import org.apache.flink.api.scala._
