flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bharathkarnam <mailbhara...@gmail.com>
Subject Getting an eeror while running the code
Date Mon, 27 Jul 2015 04:41:57 GMT
 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.

Mime
View raw message