You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by bharathkarnam <ma...@gmail.com> on 2015/07/27 06:41:57 UTC
Getting an eeror while running the code
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.
Re: Getting an eeror while running the code
Posted by Chiwan Park <ch...@apache.org>.
Oh, I confused Streaming API with Batch API. :) Stephen’s comment will help you.
Regards,
Chiwan Park
> On Jul 27, 2015, at 4:22 PM, Stephan Ewen <se...@apache.org> wrote:
>
> 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 <ch...@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 <ma...@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.
>>
>>
>>
Re: Getting an eeror while running the code
Posted by Stephan Ewen <se...@apache.org>.
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 <ch...@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 <ma...@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.
>
>
>
Re: Getting an eeror while running the code
Posted by Chiwan Park <ch...@apache.org>.
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 <ma...@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.