Compilation error while instancing FlinkKafkaConsumer082

[Simone Robutti]

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?

[rmetzger0]

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 <[hidden email]> 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?