Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id D6483200BAA for ; Thu, 27 Oct 2016 09:48:15 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id D4DFC160AF6; Thu, 27 Oct 2016 07:48:15 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id F3CFD160AE4 for ; Thu, 27 Oct 2016 09:48:14 +0200 (CEST) Received: (qmail 58547 invoked by uid 500); 27 Oct 2016 07:48:14 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 58537 invoked by uid 99); 27 Oct 2016 07:48:13 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2016 07:48:13 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 4EF91C0B4D for ; Thu, 27 Oct 2016 07:48:13 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.192 X-Spam-Level: *** X-Spam-Status: No, score=3.192 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URI_HEX=1.313] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id acCwyxo62uU7 for ; Thu, 27 Oct 2016 07:48:09 +0000 (UTC) Received: from mail-lf0-f45.google.com (mail-lf0-f45.google.com [209.85.215.45]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id B7BF65FBD4 for ; Thu, 27 Oct 2016 07:48:08 +0000 (UTC) Received: by mail-lf0-f45.google.com with SMTP id f134so19015453lfg.2 for ; Thu, 27 Oct 2016 00:48:08 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=1V4BOwEmSiVoGnzCtNBqg1zW7PWt/AP2VZivzmrkDl8=; b=K5ubtuSfyMi4p5W1RGagygtZ6Bjg11mA3k0NcZZeBcpgkLLokAtHT6dfaBDg492lxq PcdJGoNenjdzeVgHd4Blyq+xgdm+jKFMk4fwIo3g0i7/pC8NOjPWZt81YdT12QISyri5 XB0/Up/0Zmy/tuhbFT5yr64hsYvnkbB5icC1x3TtC8XJHVLrG2Nsvv244wvJMQREToaU 1ne6gIXlamiK4dvMwESrQb/TD5uhu64ABA+O/TKtjBbgQYE3KwiE302IPPiR1a0WyjoS CYJOYomDDe066cuq2S/CDFpLq7YAOYJWeWZHO30otYEwsB+P1DLAX9oWBH895g1XOoYr 4S8w== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=1V4BOwEmSiVoGnzCtNBqg1zW7PWt/AP2VZivzmrkDl8=; b=PgU7BZtMeJpl3zLHBkAYe8UJ7ASNzUeTDe4fzT59p5xuY/Q3tDDt7XyVSe4RRCnD4H mvRdXoqpEVoG51oxbGLWzpWHtEa/BBuNtRGoiGm378lWEX6h+UCDDZysi/uu3t4IAF32 S6SKw0Gmr0k5zv9/6FLNspGT1txLdDlIOkDG63yunIuhYtquV7akYRyo56qXod9msT0I OEbg3V7G7zuYhxdIw1DBz+0gm0U1phlFPmxBL4KHUwkU9b7ATloMu5aM07RKrmuxn1qB akbgf8cq/0IQCcOySp3MxBCz2iepCMxkjNgNoe7JDBS/X+8U9sFHFRur0J05nducQirr J33g== X-Gm-Message-State: ABUngvdsigdZOKhGOzs9d/zPXkDv1z0Gc/xIFcsU4zXBgTAj4ZY8lzl/E9JCH8meGEv5ZizUfAXFzWCS8GCgUw== X-Received: by 10.25.150.148 with SMTP id y142mr5120387lfd.85.1477554484274; Thu, 27 Oct 2016 00:48:04 -0700 (PDT) MIME-Version: 1.0 Received: by 10.25.133.7 with HTTP; Thu, 27 Oct 2016 00:47:33 -0700 (PDT) In-Reply-To: <1477545184155-9744.post@n4.nabble.com> References: <1477545184155-9744.post@n4.nabble.com> From: Fabian Hueske Date: Thu, 27 Oct 2016 09:47:33 +0200 Message-ID: Subject: Re: Flink Cassandra Connector is not working To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a114022382becf1053fd3f6f4 archived-at: Thu, 27 Oct 2016 07:48:16 -0000 --001a114022382becf1053fd3f6f4 Content-Type: text/plain; charset=UTF-8 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 : > Hi, > I am working on connecting Flink with Cassandra. When I ran the sample > program (which I got from Github > 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. > --001a114022382becf1053fd3f6f4 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

a NoSuchMethod indicates that y= ou 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 <= span dir=3D"ltr"><patte@innominds.com>:
Hi= ,
=C2=A0 I am working on connecting Flink with Cassandra. When I ran the samp= le
program (which I got from=C2=A0 Github
<https= ://github.com/apache/flink/tree/master/flink-streaming-connectors= /flink-connector-cassandra/src/test/java/org/apache/flink/st= reaming/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/ap= ache/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-C= onnector-is-not-working-tp9744.html
Sent from the Apache Flink User Mailing List archive. mailing list archive = at Nabble.com.

--001a114022382becf1053fd3f6f4--