You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by NagaSaiPradeep <pa...@innominds.com> on 2016/10/27 05:13:04 UTC
Flink Cassandra Connector is not working
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.
Re: Flink Cassandra Connector is not working
Posted by Fabian Hueske <fh...@gmail.com>.
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 <pa...@innominds.com>:
> 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.
>