Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6715A18A26 for ; Thu, 3 Mar 2016 21:49:36 +0000 (UTC) Received: (qmail 76864 invoked by uid 500); 3 Mar 2016 21:49:31 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 76773 invoked by uid 500); 3 Mar 2016 21:49:31 -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 76762 invoked by uid 99); 3 Mar 2016 21:49:31 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Mar 2016 21:49:31 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id B8F8BC63E1 for ; Thu, 3 Mar 2016 21:49:30 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.612 X-Spam-Level: ** X-Spam-Status: No, score=2.612 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001, URI_HEX=1.313] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id QlrJ5iQnXJS3 for ; Thu, 3 Mar 2016 21:49:29 +0000 (UTC) Received: from mail-io0-f180.google.com (mail-io0-f180.google.com [209.85.223.180]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id 76C835F570 for ; Thu, 3 Mar 2016 21:49:28 +0000 (UTC) Received: by mail-io0-f180.google.com with SMTP id g203so42593565iof.2 for ; Thu, 03 Mar 2016 13:49:28 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:date:message-id:subject :from:to; bh=C4S0hAWNUuxYoHUH7kjRo9V+L/VNOPNjfb6OVTbj9DA=; b=xHGeu5kmbhKExHADaeS80YEhunN2FdLh3M511vCBJpVvUn56KOqAtShMAVlbRwGvcK mYUj+T5U05BWo1avwm235+DKLqhk2BxKOzNC1nDPeVsqCeGA/0sRF6OUfOehcTlW5gIU +nNbPXFNX0N+iQLHd9XfimJ6njWXeOZsfT3+C4NWo1j4J8h9ylHb9A18Ln2jCiG1l1WO GVIqeIQa6aU8RkB6IwhBAk8MLcAWKpC9X0qsNRhUledAO0IldIcpE1+Ur36WztGa9MJA lAQ/8NUSwTvH2nGlnG0UGruJpIsljW+nByef4vprZXig+8d/Wwuov4bFCaM7CQq8vGd+ hyvA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:sender:in-reply-to:references:date :message-id:subject:from:to; bh=C4S0hAWNUuxYoHUH7kjRo9V+L/VNOPNjfb6OVTbj9DA=; b=bCSm4CCXgKAmqkRW4+2u4QrLyYBOd3pui70bJ2pPwrxALI9dVzxnrar6tUysCKwJTd NW7sERvpds0g5DKhDyX9c7ulRbimhzdsCqGPT+sOjXQ7ruojPFG5bTzcXXCuniLtBHZ7 pKBZQ6BuOhs4vpr8OZOoov0SzNlps6zam8XC+7bOPuNxYFInuDYFZB0VraYrcIL8VNSf 1dfmFKnenWBR3JvGLl43Gf2Mj1tnlFmqM8WinrqsEdvGWotIIOiEr5q0VfI4YnM/sCNV 9oH3dVY4olxGIfAfY1jsmY8PLMaz5JZ1BvFdz67oJxde5udD1fueaOIx4f/W76tWzK8n xmKw== X-Gm-Message-State: AD7BkJK5hXUGq33u2yq72vQjxjlm8QR+WkZy53phkg7POA53pe7CSq8ulKMRVSyi2k1F42bq3t0VOiDEgniNkg== MIME-Version: 1.0 X-Received: by 10.107.130.89 with SMTP id e86mr5068027iod.23.1457041767438; Thu, 03 Mar 2016 13:49:27 -0800 (PST) Sender: ewenstephan@gmail.com Received: by 10.107.159.194 with HTTP; Thu, 3 Mar 2016 13:49:27 -0800 (PST) In-Reply-To: <3B3D0E20-09CE-416E-8788-0278C89CFD06@capitalone.com> References: <3B3D0E20-09CE-416E-8788-0278C89CFD06@capitalone.com> Date: Thu, 3 Mar 2016 22:49:27 +0100 X-Google-Sender-Auth: a5i72XGIKfJgwSocxMxj3JYzTDA Message-ID: Subject: Re: java.lang.NoClassDefFoundError for Keys Class From: Stephan Ewen To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a113ec87ef8a50f052d2bf84f --001a113ec87ef8a50f052d2bf84f Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi! You are using some outdated dependencies. Now, all Scala-dependent Flink artifacts include the Scala Version Suffix (following common conventions) Please substitute: - flink-streaming-java--> flink-streaming-java_2.10 - flink-clients --> flink-clients_2.10 - flink-connector-kafka --> flink-connector-kafka-0.8_2.10 That should do it. FYI: You can also try to use the latest release candidate, described here: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-Release= -Apache-Flink-1-0-0-RC5-td10628.html Greetings, Stephan On Thu, Mar 3, 2016 at 10:01 PM, Madhire, Naveen < Naveen.Madhire@capitalone.com> wrote: > > Hey All, > > I am getting the below error while executing a simple Kafka-Flink > Application. > > > *java.lang.NoClassDefFoundError: org/apache/flink/api/java/operators/Keys= * > > > > > Below are the maven dependencies which I included in my application. > > > > org.apache.kafka > kafka_2.9.1 > 0.8.2.0 > > > commons-configuration > commons-configuration > 1.10 > > > org.apache.flink > flink-connector-kafka > 1.0-SNAPSHOT > > > org.apache.flink > flink-java > 1.0-SNAPSHOT > > > org.apache.flink > flink-clients > 1.0-SNAPSHOT > > > org.apache.flink > flink-streaming-java > 1.0-SNAPSHOT > > > junit > junit > 4.12 > > > > > I checked the Flink source and couldn=E2=80=99t find the org.apache.flink= .api.java.operators.Keys class. > > I found org.apache.flink.api.common.operators.Keys instead. Is there any = other Flink dependency which I am missing? > > > > Thanks, > > Naveen > > > > > ------------------------------ > > The information contained in this e-mail is confidential and/or > proprietary to Capital One and/or its affiliates and may only be used > solely in performance of work or services for Capital One. The informatio= n > transmitted herewith is intended only for use by the individual or entity > to which it is addressed. If the reader of this message is not the intend= ed > recipient, you are hereby notified that any review, retransmission, > dissemination, distribution, copying or other use of, or taking of any > action in reliance upon this information is strictly prohibited. If you > have received this communication in error, please contact the sender and > delete the material from your computer. > --001a113ec87ef8a50f052d2bf84f Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi!

You are using some outdated depende= ncies. Now, all Scala-dependent Flink artifacts include the Scala Version S= uffix (following common conventions)

Please substi= tute:
=C2=A0 - flink-streaming-java--> flink-streaming-java_2.= 10
=C2=A0 - flink-clients --> flink-clients_2.10
=
=C2=A0 - flink-connector-kafka --> flink-connector-kafka-0.8_2.10

That should do it.

FYI= : =C2=A0You can also try to use the latest release candidate, described her= e:=C2=A0http://apache-flin= k-mailing-list-archive.1008284.n3.nabble.com/VOTE-Release-Apache-Flink-1-0-= 0-RC5-td10628.html

Greetings,
Stepha= n


On Thu, Mar 3, 2016 at 10:01 PM, Madhire, Naveen <N= aveen.Madhire@capitalone.com> wrote:

Hey All,

I am getting the below error while executing a simple Kafka-Flink Applicati= on.


java.lang.NoClassDefFoundError: org/apache/flink/api/java/operators/Keys=




Below are the maven dependencies which I included in my application.=C2=A0<= /div> 


<dependency>
=
   <groupId>org.apache.kafka</groupId>
   &l=
t;artifactId>=
kafka_2.9.1</artifactId>
   <version>0.8.2.0</version>
</dependency>
 <dependency>
   <=
groupId>commo=
ns-configuration</groupId>
   <artifactId>commons-configuration</artifactId>
   <<=
/span>version>1.10</version>
 </dependency>
 <depend=
ency>
   <groupId>org.apache.flink</groupId>
   <ar=
tifactId>flink-co=
nnector-kafka</artifactId>
   <version>1.0-SNAPSHOT</version>=

 </dependency>
 <dependency>
   <groupId>org.apache.flink</groupId<=
/span>>
   <artifactId>flink-java</artifactId>
   <version=
>1.0-SNAPSHOT</version>
 </dependency=
>
 <dependency=
>
   <groupId>org.apache.flink</groupId>
   <artifa=
ctId>flink-client=
s</artifactId>
   <version>1.0-SNAPSHOT</=
version>
 =
</dependency>
 <dependency>
   <gr=
oupId>org.apache.=
flink</groupId>
   <artifactId>flink-streaming-java</artifactId&=
gt;
   <version>1.0-SNAPSHOT</version>
 </dependency&g=
t;
 <dependency>
   <groupId>junit=
</groupId>=

   <artifactId>junit</artifactId>
   <=
;version>4.12=
</version>
 </dependency>


I checked the Flink =
source and couldn=E2=80=99t find the org.apache.flink.api.java.operators.Ke=
ys class.
I found org.apache.flink.api.common.operators.Keys instead. Is there any other Flink depend=
ency which I am missing?


Tha=
nks,
Naveen



=20

The information contain= ed in this e-mail is confidential and/or proprietary to Capital One and/or = its affiliates and may only be used solely in performance of work or servic= es for Capital One. The information transmitted herewith is intended only f= or use by the individual or entity to which it is addressed. If the reader = of this message is not the intended recipient, you are hereby notified that= any review, retransmission, dissemination, distribution, copying or other = use of, or taking of any action in reliance upon this information is strict= ly prohibited. If you have received this communication in error, please con= tact the sender and delete the material from your computer.


--001a113ec87ef8a50f052d2bf84f--