Fwd: Exception in WordCount code.

[arunima]

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