Hi all,
I am new to Apache Flink and I followed http://training.data-
artisans.com/devEnvSetup.html
to start with Flink setup and sample code demo.
I am facing issue while running WordCount.java code in eclipse IDE.
I am getting " java.lang.NoClassDefFoundError:
org/jboss/netty/logging/InternalLoggerFactory"
exception.
Below is the console output -
19:35:33,364 INFO org.apache.flink.api.java.ExecutionEnvironment
- The job has 0 registered types and 0 default Kryo serializers
19:35:33,643 INFO org.apache.flink.runtime.minicluster.FlinkMiniCluster
- Disabled queryable state server
Exception in thread "main" java.lang.NoClassDefFoundError:
org/jboss/netty/logging/InternalLoggerFactory
at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<
init>(FlinkMiniCluster.scala:90)
at org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster.<init>(
LocalFlinkMiniCluster.scala:65)
at org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster.<init>(
LocalFlinkMiniCluster.scala:74)
at org.apache.flink.client.LocalExecutor.start(LocalExecutor.java:115)
at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:176)
at org.apache.flink.api.java.LocalEnvironment.execute(
LocalEnvironment.java:91)
at org.apache.flink.api.java.ExecutionEnvironment.execute(
ExecutionEnvironment.java:926)
at org.apache.flink.api.java.DataSet.collect(DataSet.java:410)
at org.apache.flink.api.java.DataSet.print(DataSet.java:1605)
at org.apache.flink.quickstart.WordCount.main(WordCount.java:59)
Caused by: java.lang.ClassNotFoundException: org.jboss.netty.logging.
InternalLoggerFactory
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 10 more
Please help me out.
Thanks in Advance.
Regards,
Arunima Singh
