Your program gives this exception: java.lang.UnsupportedClassVersionError: This usually means that a JVM tries to load code that has been compiled with a newer Java version. For example, Java 7 running a Java 8 program.
Per stack Overflow: http://stackoverflow.com/questions/10382929/how-to-fix-unsupported-major-minor-version-51-0-error On Mon, Jul 27, 2015 at 7:22 AM, Chiwan Park <chiwanp...@apache.org> wrote: > Hi, print() method runs the program immediately. After execution, there is > no sink in > the program. You should remove calling execute() method after calling > print() method. > > There is more detail description [1][2] in Flink documentation. I hope > that this helps. > > Regards, > Chiwan Park > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-0.9/apis/programming_guide.html#lazy-evaluation > [2] > https://ci.apache.org/projects/flink/flink-docs-release-0.9/apis/programming_guide.html#data-sinks > > > On Jul 27, 2015, at 1:41 PM, bharathkarnam <mailbhara...@gmail.com> > wrote: > > > > 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.<init>(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<String>("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. > > >
