Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 9569D18759 for ; Mon, 27 Jul 2015 04:54:10 +0000 (UTC) Received: (qmail 47746 invoked by uid 500); 27 Jul 2015 04:54:10 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 47677 invoked by uid 500); 27 Jul 2015 04:54:10 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Delivered-To: moderator for dev@flink.apache.org Received: (qmail 39609 invoked by uid 99); 27 Jul 2015 04:42:18 -0000 X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.515 X-Spam-Level: ** X-Spam-Status: No, score=2.515 tagged_above=-999 required=6.31 tests=[DKIM_ADSP_CUSTOM_MED=0.001, NML_ADSP_CUSTOM_MED=1.2, URIBL_BLOCKED=0.001, URI_HEX=1.313] autolearn=disabled Date: Sun, 26 Jul 2015 21:41:57 -0700 (MST) From: bharathkarnam To: dev@flink.apache.org Message-ID: <1437972117398-7154.post@n3.nabble.com> Subject: Getting an eeror while running the code MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit bin/flink run -c com.hello.flink.StreamData /home/a544403/Flinkstream.jar org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'com.hello.flink.StreamData' could not be loaded due to a linkage failure. at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:527) at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:142) at org.apache.flink.client.CliFrontend.buildProgram(CliFrontend.java:654) at org.apache.flink.client.CliFrontend.run(CliFrontend.java:256) at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:880) at org.apache.flink.client.CliFrontend.main(CliFrontend.java:922) Caused by: java.lang.UnsupportedClassVersionError: com/hello/flink/StreamData : Unsupported major.minor version 52.0 at java.lang.ClassLoader.defineClass1(Native Method) at java.lang.ClassLoader.defineClass(ClassLoader.java:800) at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) at java.net.URLClassLoader.defineClass(URLClassLoader.java:449) at java.net.URLClassLoader.access$100(URLClassLoader.java:71) at java.net.URLClassLoader$1.run(URLClassLoader.java:361) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:425) at java.lang.ClassLoader.loadClass(ClassLoader.java:358) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:274) at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:516) ... 5 more here is my code package com.hello.flink; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.connectors.kafka.api.KafkaSource; import org.apache.flink.streaming.util.serialization.SimpleStringSchema; public class StreamData { public static void main(String[] args) { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.addSource(new KafkaSource("localhost:2181", "syslog_framework", new SimpleStringSchema())).print(); try { env.execute("MyJob"); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Getting-an-eeror-while-running-the-code-tp7154.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.