Hi,
which build system are you using? Can you maybe post the configuration file
of that build system ? (pom.xml / sbt file).
I suspect that some of the dependencies are wrong. Maybe not all have the
right scala version suffix or there is a version mix.
On Wed, Feb 10, 2016 at 5:17 PM, Simone Rob
Hello,
the compiler has been raising an error since I added this line to the code
val testData=streamEnv.addSource(new
FlinkKafkaConsumer082[String]("data-input",new
SimpleStringSchema(),kafkaProp))
Here is the error:
Error:scalac: Class
org.apache.flink.streaming.api.checkpoint.CheckpointN
