flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "PACE, JAMES" <jp4...@att.com>
Subject Flink - Nifi Connectors - Class not found
Date Fri, 11 Nov 2016 20:23:39 GMT
I am running Apache Flink 1.1.3 - Hadoop version 1.2.1 with the NiFi connector.  When I run
a program with a single NiFi Source, I receive the following Stack trace in the logs:



2016-11-11 19:28:25,661 WARN  org.apache.flink.client.CliFrontend

            - Unable to locate custom CLI class org.apache.flink.yarn.cli.FlinkYarnSessionCli.
Flink is not compiled with support for this class.

java.lang.ClassNotFoundException: org.apache.flink.yarn.cli.FlinkYarnSessionCli

        at java.net.URLClassLoader$1.run(URLClassLoader.java:366)

        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 sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:358)

        at java.lang.Class.forName0(Native Method)

        at java.lang.Class.forName(Class.java:195)

       at org.apache.flink.client.CliFrontend.loadCustomCommandLine(CliFrontend.java:1136)

        at org.apache.flink.client.CliFrontend.<clinit>(CliFrontend.java:128)

2016-11-11 19:28:25,855 INFO  org.apache.flink.client.CliFrontend

2016-11-11 19:28:25,855 INFO  org.apache.flink.client.CliFrontend

            -  Starting Command Line Client (Version: 1.1.3, Rev:8e8d454, Date:10.10.2016
@ 13:26:32 UTC)

2016-11-11 19:28:25,855 INFO  org.apache.flink.client.CliFrontend

            -  Current user: xxxxx

2016-11-11 19:28:25,856 INFO  org.apache.flink.client.CliFrontend

            -  JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.7/24.80-b11

2016-11-11 19:28:25,856 INFO  org.apache.flink.client.CliFrontend

            -  Maximum heap size: 3545 MiBytes

2016-11-11 19:28:25,866 INFO  org.apache.flink.client.CliFrontend

            -  Hadoop version: 1.2.1



Seems like the Nifi connector requires the yarn enabled version of flink?  Is there a dependency
I can add to get over this hurdle?



Thanks



Jim


Mime
View raw message