diff --git a/pom.xml b/pom.xml
index f561bbf..49c1ade 100644
--- a/pom.xml
+++ b/pom.xml
@@ -36,6 +36,12 @@
Patrik at Bintray
http://dl.bintray.com/patriknw/maven
+
+
+ gearpump-shaded-repo
+ Vincent at Bintray
+ http://dl.bintray.com/fvunicorn/maven
+
@@ -43,11 +49,13 @@
com.github.intel-hadoop
gearpump-core_2.11
${gearpumpVersion}
+ provided
com.github.intel-hadoop
gearpump-streaming_2.11
${gearpumpVersion}
+ provided
com.github.intel-hadoop
@@ -63,6 +71,23 @@
+
+ maven-assembly-plugin
+
+
+ jar-with-dependencies
+
+
+
+
+ make-assembly
+ package
+
+ single
+
+
+
+
org.apache.maven.plugins
maven-compiler-plugin
diff --git a/src/main/java/kafka/Sum.java b/src/main/java/kafka/Sum.java
index 9150caa..1a10a0c 100644
--- 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;