fix #4, fix build failure

gearpump · Sep 29, 2015 · cb696e2 · cb696e2
1 parent 532083e
commit cb696e2
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 1 deletion.
diff --git a/pom.xml b/pom.xml
@@ -36,18 +36,26 @@
             <name>Patrik at Bintray</name>
             <url>http://dl.bintray.com/patriknw/maven</url>
         </repository>
+
+        <repository>
+            <id>gearpump-shaded-repo</id>
+            <name>Vincent at Bintray</name>
+            <url>http://dl.bintray.com/fvunicorn/maven</url>
+        </repository>
     </repositories>
 
     <dependencies>
         <dependency>
             <groupId>com.github.intel-hadoop</groupId>
             <artifactId>gearpump-core_2.11</artifactId>
             <version>${gearpumpVersion}</version>
+            <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>com.github.intel-hadoop</groupId>
             <artifactId>gearpump-streaming_2.11</artifactId>
             <version>${gearpumpVersion}</version>
+            <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>com.github.intel-hadoop</groupId>
@@ -63,6 +71,23 @@
 
     <build>
         <plugins>
+            <plugin>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <configuration>
+                    <descriptorRefs>
+                        <descriptorRef>jar-with-dependencies</descriptorRef>
+                    </descriptorRefs>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>make-assembly</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>

diff --git a/src/main/java/kafka/Sum.java b/src/main/java/kafka/Sum.java
@@ -44,7 +44,7 @@ public void onStart(StartTime startTime) {
 
   @Override
   public void onNext(Message message) {
-    String word = (String)(message.msg());
+    String word = (String) (message.msg());
     Integer current = wordCount.get(word);
     if (current == null) {
       current = 0;