Getting an eeror while running the code

[bharathkarnam]

 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.