Flink Cassandra Connector is not working

[NagaSaiPradeep]

Hi,
  I am working on connecting Flink with Cassandra. When I ran the sample program (which I got from Github), I am getting the following error:

Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.streaming.api.datastream.DataStreamSink.name(Ljava/lang/String;)Lorg/apache/flink/streaming/api/datastream/DataStreamSink; at org.apache.flink.streaming.connectors.cassandra.CassandraSink$CassandraPojoSinkBuilder.build(CassandraSink.java:325)


Regards

[Fabian Hueske-2]

Hi,

a NoSuchMethod indicates that you are using incompatible versions.
You should check that the versions of your job dependencies and the version cluster you want to run the job on are the same.

Best, Fabian

2016-10-27 7:13 GMT+02:00 NagaSaiPradeep <[hidden email]>:

Hi,
  I am working on connecting Flink with Cassandra. When I ran the sample
program (which I got from  Github
<https://github.com/apache/flink/tree/master/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example>
), I am getting the following error:

Exception in thread "main" java.lang.NoSuchMethodError:
org.apache.flink.streaming.api.datastream.DataStreamSink.name(Ljava/lang/String;)Lorg/apache/flink/streaming/api/datastream/DataStreamSink;
at
org.apache.flink.streaming.connectors.cassandra.CassandraSink$CassandraPojoSinkBuilder.build(CassandraSink.java:325)


Regards



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Cassandra-Connector-is-not-working-tp9744.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.