Issue running basic example locally

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Issue running basic example locally

Andres Angel
Hello everyone, 

I'm using IntelliJ in a ubuntu environment with java 1.8 to run my Flink framworks. My goal is consume few kinesis stream services and build a sort of pipeline. Initially I have build my pom.xml file attached and a test java class attached too.

However , once I run my class from the IDE and getting this error:

Error: A JNI error has occurred, please check your installation and try again
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
at java.lang.Class.getMethod0(Class.java:3018)
at java.lang.Class.getMethod(Class.java:1784)
at sun.launcher.LauncherHelper.validateMainClass(LauncherHelper.java:544)
at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:526)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 7 more

I think I dont need to install or consifure any flink service before run my job via IDE , please if someone could give me a hand with this issue I would appreciate it.

thanks 



pom.xml (4K) Download Attachment
Reply | Threaded
Open this post in threaded view
|

Re: Issue running basic example locally

Caizhi Weng
Hi Andres,

`<scope>provided</scope>` of flink-streaming-java seems suspicious, can you
remove it and see what happens?

Andres Angel <[hidden email]> 于2019年7月19日周五 上午3:10写道:

> Hello everyone,
>
> I'm using IntelliJ in a ubuntu environment with java 1.8 to run my Flink
> framworks. My goal is consume few kinesis stream services and build a sort
> of pipeline. Initially I have build my pom.xml file attached and a test
> java class attached too.
>
> However , once I run my class from the IDE and getting this error:
>
> Error: A JNI error has occurred, please check your installation and try
> again
> Exception in thread "main" java.lang.NoClassDefFoundError:
> org/apache/flink/streaming/api/functions/source/SourceFunction
> at java.lang.Class.getDeclaredMethods0(Native Method)
> at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
> at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
> at java.lang.Class.getMethod0(Class.java:3018)
> at java.lang.Class.getMethod(Class.java:1784)
> at sun.launcher.LauncherHelper.validateMainClass(LauncherHelper.java:544)
> at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:526)
> Caused by: java.lang.ClassNotFoundException:
> org.apache.flink.streaming.api.functions.source.SourceFunction
> at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> ... 7 more
>
> I think I dont need to install or consifure any flink service before run
> my job via IDE , please if someone could give me a hand with this issue I
> would appreciate it.
>
> thanks
>
>
>
Reply | Threaded
Open this post in threaded view
|

Re: Issue running basic example locally

Andres Angel
that was the issue , thanks so much man!!
AU

On Thu, Jul 18, 2019 at 8:56 PM Caizhi Weng <[hidden email]> wrote:

> Hi Andres,
>
> `<scope>provided</scope>` of flink-streaming-java seems suspicious, can you
> remove it and see what happens?
>
> Andres Angel <[hidden email]> 于2019年7月19日周五 上午3:10写道:
>
> > Hello everyone,
> >
> > I'm using IntelliJ in a ubuntu environment with java 1.8 to run my Flink
> > framworks. My goal is consume few kinesis stream services and build a
> sort
> > of pipeline. Initially I have build my pom.xml file attached and a test
> > java class attached too.
> >
> > However , once I run my class from the IDE and getting this error:
> >
> > Error: A JNI error has occurred, please check your installation and try
> > again
> > Exception in thread "main" java.lang.NoClassDefFoundError:
> > org/apache/flink/streaming/api/functions/source/SourceFunction
> > at java.lang.Class.getDeclaredMethods0(Native Method)
> > at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
> > at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
> > at java.lang.Class.getMethod0(Class.java:3018)
> > at java.lang.Class.getMethod(Class.java:1784)
> > at sun.launcher.LauncherHelper.validateMainClass(LauncherHelper.java:544)
> > at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:526)
> > Caused by: java.lang.ClassNotFoundException:
> > org.apache.flink.streaming.api.functions.source.SourceFunction
> > at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
> > at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
> > at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> > ... 7 more
> >
> > I think I dont need to install or consifure any flink service before run
> > my job via IDE , please if someone could give me a hand with this issue I
> > would appreciate it.
> >
> > thanks
> >
> >
> >
>