Hi=C2=A0

I am seeing the following erro= r when i am trying to run the jar in Flink Cluster. I am not sure what depe= ndency is missing.

=C2=A0/opt/DataHUB/flink-0= .10.1/bin/flink =C2=A0run datahub-heka-1.0-SNAPSHOT.jar flink.properties

java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce= $class

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at kafka.utils.Pool.<init&g= t;(Pool.scala:28)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at kafka.consumer.F= etchRequestAndResponseStatsRegistry$.<init>(FetchRequestAndResponseSt= ats.scala:60)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at kafka.consumer.Fetch= RequestAndResponseStatsRegistry$.<clinit>(FetchRequestAndResponseStat= s.scala)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at kafka.consumer.SimpleCons= umer.<init>(SimpleConsumer.scala:39)

=C2=A0 =C2=A0 =C2=A0 = =C2=A0 at kafka.javaapi.consumer.SimpleConsumer.<init>(SimpleConsumer= .scala:34)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.stream= ing.connectors.kafka.FlinkKafkaConsumer.getPartitionsForTopic(FlinkKafkaCon= sumer.java:691)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.s= treaming.connectors.kafka.FlinkKafkaConsumer.<init>(FlinkKafkaConsume= r.java:281)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.strea= ming.connectors.kafka.FlinkKafkaConsumer082.<init>(FlinkKafkaConsumer= 082.java:49)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at com.lmig.datahub.heka= .Main.main(Main.java:39)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.refle= ct.NativeMethodAccessorImpl.invoke0(Native Method)

=C2=A0 =C2=A0 = =C2=A0 =C2=A0 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAc= cessorImpl.java:62)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.reflect.De= legatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.reflect.Method.invoke(Metho= d.java:497)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.clien= t.program.PackagedProgram.callMainMethod(PackagedProgram.java:497)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.client.program.PackagedPr= ogram.invokeInteractiveModeForExecution(PackagedProgram.java:395)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.client.program.Client.runB= locking(Client.java:252)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apach= e.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:676)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.client.CliFrontend.r= un(CliFrontend.java:326)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apach= e.flink.client.CliFrontend.parseParameters(CliFrontend.java:978)

= =C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.client.CliFrontend.main(Cli= Frontend.java:1028)

Caused by: java.lang.ClassNotFoundException: = scala.collection.GenTraversableOnce$class

=C2=A0 =C2=A0 =C2=A0 = =C2=A0 at java.net.URLClassLoader.findClass(URLClassLoader.java:381)

<= div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.ClassLoader.loadClass(ClassLoa= der.java:424)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.ClassLoade= r.loadClass(ClassLoader.java:357)

=C2=A0 =C2=A0 =C2=A0 =C2=A0 ...= 20 more

The exception above occurred while trying= to run your command.

Here is= my pom.xml:

<?xml version=3D"1.0" =
encoding=3D"UTF-8"?>
<project xmlns=
=3D"http://maven.apache.=
org/POM/4.0.0"
         xml=
ns:xsi=3D"http://www.w3.org/2001/XMLSchema-instance<=
/a>"
         xsi:schemaLocation=3D"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.=
0.0.xsd"&=
gt;
    <modelVersion>4.0.0=
</modelVersion>

    <groupId>com.datahub</groupId>
    <artifactId>datahub-heka</artifactId<=
/span>>
    =
<ver=
sion>1.0=
-SNAPSHOT</version>=

    <dependencies>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifa=
ctId>fli=
nk-java</artifactId>=
;
            &=
lt;version>0.10.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.f=
link</groupId>
            <artifactId>flink-streaming-java</artifactId>
            <version>0.10.1</version>
        </dependenc=
y>
  =
      <dependency><=
/span>
            <=
;groupId>org.apache.flink</groupId>
            <artifactId>flink-clients</artifactId>
      =
      <version>0.10.1</version>=

        </<=
/span>dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            =
<art=
ifactId>=
kafka_2.10</artifactId=
>
            <version>0.8.2.2</version>
        </dependency>
        <dependency>
            <groupId<=
/span>>org.apac=
he.flink</groupId><=
/span>
            <=
;artifactId>flink-connector-kafka</artifactId>
            <version>0.10.1</version>
        <=
span style=3D"background-color:rgb(239,239,239)"></dep=
endency>=

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-elas=
ticsearch</artifactId&=
gt;
            <version>0.10.1</version>
        </dependency>
        <dependency>
            <groupId>org.elasti=
csearch</groupId>
            <=
artifactId>elasticsearch</artifactId>
            <version>1.7.2</version>
        </dependency>
     =
   <=
dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch-shield</artifactId=
>
   =
         <version><=
/span>1.3.3</version&g=
t;
        <=
/dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
         =
   <=
artifactId>elasticsearch-license-plugin</artifactId>
            <version>1.0.0</version>
        </dependency>
      =
  <=
dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactI=
d>
  =
          <version>=
2.6.4</<=
span style=3D"color:rgb(0,0,128);font-weight:bold;background-color:rgb(239,=
239,239)">version&=
gt;
        <=
;/dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.cor=
e</=
groupId>=

            <artifactId>jackson-databind</artifactId>
            <version>2.6.4</version>
        </dependency>
    </depe=
ndencies>
    <repositories=
>
        &l=
t;repository>
            <id>elasticsearch-releases</id>
            <url>http://maven.elasticsearch.org/releases</=
url>
=
            <releases&=
gt;
                <enabled>true</enabled>
            </releases>
            <snapshots>
            =
    <enabled>false</enabled>
            </=
snapshots>
        </repository>
    </repositories>
    <build>
        <plugins>
            <!-- We use the ma=
ven-shade plugin to create a fat jar that contains all dependencies
            exc=
ept flink and it's transitive dependencies. The resulting fat-jar can b=
e executed
            on a cluster. Change the value of Program-Class if your prog=
ram entry point changes. -->
            <plugin>
                <groupId>org.apache.maven.pl=
ugins</groupId>
                &l=
t;artifactId>maven-shade-plugin</artifactId>
                <version=
>2.4.1</version>
       =
         <executions&g=
t;
                    <!-- Run shade goal on package phase -->
                    <=
/span><execution>
                        <phase>package</phase>
                        <goals>
                 =
           <goal>shade</goal>
                        </goals>
                        <configuration<=
span style=3D"background-color:rgb(239,239,239)">>
           =
                 <artifactSet>
                                <excludes>
                   =
                 &=
lt;!-- This list contains all dependencies of flink-dist
                          =
          Everything else will be packaged into the fat-jar
                       =
             -->
                                    <exclude>org.apache.flink:flink-=
shaded-*</exclude><=
/span>
                                    <exclude>org.apache.flink:flink-core</exclude=
>
   =
                                 <exclude>org.apache.flink:flink-java</exclude>
                =
                    <<=
/span>exclude>org.apache.flink:flink-scala</exclude>
                            =
        <exclude>org.apache.flink:flink-runtime</exclude>
                                    <exclu=
de>org.a=
pache.flink:flink-optimizer</exclude>
                                    <exclude>org.apache.fl=
ink:flink-clients</exclude>
                                    <exclude>org.apache.flink:flink-=
avro</exclude>
                                    <exclude>org.apache.flink:flink-java-examples=
</=
exclude>=

                                    <exclude>org.apache.flink:flink-scala-examples<=
span style=3D"background-color:rgb(239,239,239)"></exc=
lude>                                    <exclude>org.apache.flink:flink-streaming-examples=
</=
exclude>=

                                    <exclude>org.apache.flink:flink-streaming-java<=
span style=3D"background-color:rgb(239,239,239)"></exc=
lude>
                                    <!-- Also exclude very big transitive dependencie=
s of Flink
                                    WARNING: You have to remove these ex=
cludes if your code relies on other
                                    versions of=
 these dependencies.
                                    -->
                           =
         <exclude>org.scala-lang:scala-library</exclude>
                                =
    <exclude>org.scala-lang:scala-compiler</exclude>
                                    <exclude>org.scala-=
lang:scala-reflect</exclude>
                                    <exclude>com.amazonaws:aws-java=
-sdk</exclude>
                                    <exclude>com.typesafe.akka:akka-actor_*</exclude<=
/span>>
    =
                                <exclude>com.typesafe.akka:akka-remote_*</exclude>
             =
                       &l=
t;exclude>com.typesafe.akka:akka-slf4j_*</exclude>
                     =
               <exclude>io.netty:netty-all</exclude>
                                    <exclude>io.netty:n=
etty</exclude>
                                    <exclude>org.eclipse.jetty:jetty-server</exclude<=
/span>>
    =
                                <exclude>org.eclipse.jetty:jetty-continuation</exclude>
        =
                            <exclude>org.eclipse.jetty:jetty-http</exclude>
                    =
                <exclude>org.eclipse.jetty:jetty-io</exclude>
                                  =
  <=
exclude>=
org.eclipse.jetty:jetty-util</exclude>
                                    <exclude>org.eclipse.=
jetty:jetty-security</=
exclude>
                                    <exclude>org.eclipse.jetty:je=
tty-servlet</exclude&g=
t;
                                    <exclude>commons-fileupload:commons-fi=
leupload</exclude><=
/span>
                                    <exclude>org.apache.avro:avro</exclude>
         =
                           <exclude>commons-collections:commons-collections</exclude>
         =
                           <exclude>org.codehaus.jackson:jackson-core-asl</exclude>
            =
                        &=
lt;exclude>org.codehaus.jackson:jackson-mapper-asl</exclude>
             =
                       &l=
t;exclude>com.thoughtworks.paranamer:paranamer</exclude>
                 =
                   <exclude>org.xerial.snappy:snappy-java</exclude>
                            =
        <exclude>org.apache.commons:commons-compress</exclude>
                                 =
   <=
exclude>=
org.tukaani:xz</exclude>
                                    <exclude>com.esotericsoftware.kryo=
:kryo</exclude>
                                    <exclude>com.esotericsoftware.minlog:minlog<=
span style=3D"background-color:rgb(239,239,239)"></exc=
lude>                                    <exclude>org.objenesis:objenesis</exclude>
                =
                    <<=
/span>exclude>com.twitter:chill_*</exclude>
                                    <=
span style=3D"background-color:rgb(239,239,239)"><excl=
ude>com.=
twitter:chill-java</exclude>
                                    <exclude>com.twitter:chill-avro=
_*</=
exclude>=

                                    <exclude>com.twitter:chill-bijection_*</exclude>
       =
                             <exclude>com.twitter:bijection-core_*</exclude>
                   =
                 <exclude>com.twitter:bijection-avro_*</exclude>
                               =
     <exclude>commons-lang:commons-lang</exclude>
                                    <exclude>junit:junit</excl=
ude>
=
                                    <exclude>de.javakaffee:kryo-serializers</exclude>
         =
                           <exclude>joda-time:joda-time</exclude>
                              =
      <exclude>org.apache.commons:commons-lang3</exclude>
                                    <exclu=
de>org.s=
lf4j:slf4j-api</exclude>
                                    <exclude>org.slf4j:slf4j-log4j12</excl=
ude>
=
                                    <exclude>log4j:log4j</exclude>
                             =
       <exclude>org.apache.commons:commons-math</exclude>
                                    <exclu=
de>org.a=
pache.sling:org.apache.sling.commons.json</exclude>
                                =
    <exclude>commons-logging:commons-logging</exclude>
                                    <exclude<=
/span>>org.apac=
he.httpcomponents:httpclient</exclude>
                                    <exclude>org.apache.h=
ttpcomponents:httpcore<=
;/exclude>
                                    <exclude>commons-codec:comm=
ons-codec</exclude>=

                                    <exclude>com.fasterxml.jackson.core:jack=
son-core</exclude><=
/span>
                                    <exclude>com.fasterxml.jackson.core:jacks=
on-databind</exclude&g=
t;
                                    <exclude>com.fasterxml.jackson.core:ja=
ckson-annotations</exclude>
                                    <exclude>org.codehaus.jettison:j=
ettison</exclude>
                                    <exclude>stax:stax-api</exclude>
                  =
                  <exclude>com.typesafe:config</exclude>
                                    <exclud=
e>org.un=
commons.maths:uncommons-maths</exclude>
                                    <exclude>com.github.=
scopt:scopt_*</=
exclude=
>
                                    <exclude>org.mortbay.jetty:servlet=
-api</exclude>
                                    <exclude>commons-io:commons-io</exclude>
             =
                       &l=
t;exclude>commons-cli:commons-cli</exclude>
                              =
  </=
excludes>
                            </artifactSet>
                            <filters>
       =
                         =
<filter>
                                    <artifact>org.apache.flink=
:*</=
artifact>
                                    <excludes>
                                =
        <exclude>org/apache/flink/shaded/**</exclude>
                                        <exclu=
de>web-d=
ocs/**</exclude>
                                    </excludes>
                            =
    </filter>
                                <filter>
                                    <!-- Do not copy =
the signatures in the META-INF folder.
                                    Otherwis=
e, this might cause SecurityExceptions when using the JAR. -->
                 =
                   <artifact>*:*</artifact>
                                    <excludes>
       =
                                 <exclude>META-INF/*.SF</exclude>
                              =
          <exclude>=
META-INF/*.DSA<=
/exclude>
                                        <exclude=
>META-INF/*.RSA=
</=
exclude>=

                                    </excludes>
                                =
</=
filter><=
br>                            </filters>
                            <transformers>
        =
                        <!-- add Main-Class to manifest file -->
                             =
   <transformer implementation=3D&qu=
ot;org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"=
;>
  =
                                  <mainClass>com.datahub.heka.Main</mainClass>
                 =
               </transformer>
                            </transformers>
                   =
         <createDependencyReducedPom>false</createDependencyReducedPom>
                        =
</=
configuration><=
/span>
                    </execution>
                </executions>
            </plugin>

   =
         <!-- C=
onfigure the jar plugin to add the main class as a manifest entry -->          =
  <plugin>
                =
<groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-jar-p=
lugin</artifactId><=
/span>
                <version>2.5</version>
                <configuration>
                    <archive=
>
   =
                     <=
manifestEntries>
                            <Main-Class>com.datahub.heka.=
Main</Main-Class>
                        </manifestEntries>
                    </archive>
         =
       </configuration=
>
            </plugin>

            <plugin>
                <groupId>org.apache.maven.p=
lugins</groupId>
                &=
lt;artifactId>maven-compiler-plugin</artifactId>
                <version>3.1</version>
       =
         <configuration>
                    <source>1.8</source> <!-- If you want to use Java 8, change this to "1.8&=
quot; -->
                    <target>1.8</target> <!-- If you want to use Java 8, change this to "1.8"=
; -->
                &=
lt;/configuration>
            </plugin>
        </plugins>


    </build>
    <profile=
s>
  =
      <profile>
            <!-- A profile that does everyting correctly:
            We set the Flink depe=
ndencies to provided -->
            <id>build-jar</id>
            <activation>
                <activeBy=
Default>=
false</activeByDefault=
>
            </activation>
            <dependencies>
                <dependency>
     =
               <groupId>org.apache.flink</groupId>
                    <artifactId>flink-java</artifactId=
>
          =
          <version>=
0.10.1</=
version=
>
                    <scope>provided</scope>
                </dependency>
                =
<dep=
endency>=

                    &=
lt;groupId>org.apache.flink</groupId>
                    <artifactId>flink-streaming-=
java</artifactId>
                    <version>0.10.1</version>
                    <scope>provided</scope>
                <=
span style=3D"background-color:rgb(239,239,239)"></dep=
endency>=

                <<=
/span>dependency>
                    <groupId>org.apache.flink</groupId>
                =
    <artifactId>flink-clients</artifactId>
                    <version>0.10.1</version>
                    <scope>provided</scope>
     =
           </dependency>
            </dependencies>
        </profile>
    </profiles>
</project>

Any help is appreciated.

Thanks