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.madh...@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. > > > <dependency> > <groupId>org.apache.kafka</groupId> > <artifactId>kafka_2.9.1</artifactId> > <version>0.8.2.0</version> > </dependency> > <dependency> > <groupId>commons-configuration</groupId> > <artifactId>commons-configuration</artifactId> > <version>1.10</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-connector-kafka</artifactId> > <version>1.0-SNAPSHOT</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-java</artifactId> > <version>1.0-SNAPSHOT</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-clients</artifactId> > <version>1.0-SNAPSHOT</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-streaming-java</artifactId> > <version>1.0-SNAPSHOT</version> > </dependency> > <dependency> > <groupId>junit</groupId> > <artifactId>junit</artifactId> > <version>4.12</version> > </dependency> > > > > I checked the Flink source and couldn’t 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 information > 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 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 strictly prohibited. If you > have received this communication in error, please contact the sender and > delete the material from your computer. >
