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.CheckpointNotifier not found -
continuing with a stub.
Error:scalac: Class
org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema
not found - continuing with a stub.
Warning:scalac: Class
org.apache.flink.streaming.util.serialization.KeyedDeserializationSchema
not found - continuing with a stub.
Warning:scalac: Class
org.apache.flink.streaming.api.checkpoint.CheckpointNotifier not found -
continuing with a stub.
I've been using the 1.0-Snapshot version built with scala 2.11. Any
suggestion?
