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 Robutti <
simone.robu...@radicalbit.io> wrote:
> 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?
>
