diff --git a/pom.xml b/pom.xml
index 379771f..ef829ad 100644
--- a/pom.xml
+++ b/pom.xml
@@ -20,17 +20,32 @@
 
   <dependencies>
 
-    <dependency>
-      <groupId>org.apache.flink</groupId>
-      <artifactId>flink-scala_2.11</artifactId>
-      <version>1.7.0</version>
-    </dependency>
+      <dependency>
+          <groupId>org.apache.flink</groupId>
+          <artifactId>flink-java</artifactId>
+          <version>1.10.0</version>
+      </dependency>
+      <dependency>
+          <groupId>org.apache.flink</groupId>
+          <artifactId>flink-streaming-java_2.11</artifactId>
+          <version>1.10.0</version>
+      </dependency>
+      <dependency>
+          <groupId>org.apache.flink</groupId>
+          <artifactId>flink-clients_2.11</artifactId>
+          <version>1.10.0</version>
+      </dependency>
 
-    <dependency>
-      <groupId>org.apache.flink</groupId>
-      <artifactId>flink-streaming-scala_2.11</artifactId>
-      <version>1.7.0</version>
-    </dependency>
+      <dependency>
+          <groupId>org.apache.flink</groupId>
+          <artifactId>statefun-sdk</artifactId>
+          <version>2.0.0</version>
+      </dependency>
+      <dependency>
+          <groupId>org.apache.flink</groupId>
+          <artifactId>statefun-flink-harness</artifactId>
+          <version>2.0.0</version>
+      </dependency>
 
     <dependency>
       <groupId>junit</groupId>
@@ -80,45 +95,6 @@
           </executions>
         </plugin>
 
-        <!-- clean lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#clean_Lifecycle -->
-        <plugin>
-          <artifactId>maven-clean-plugin</artifactId>
-          <version>3.1.0</version>
-        </plugin>
-        <!-- default lifecycle, jar packaging: see https://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->
-        <plugin>
-          <artifactId>maven-resources-plugin</artifactId>
-          <version>3.0.2</version>
-        </plugin>
-        <plugin>
-          <artifactId>maven-compiler-plugin</artifactId>
-          <version>3.8.0</version>
-        </plugin>
-        <plugin>
-          <artifactId>maven-surefire-plugin</artifactId>
-          <version>2.22.1</version>
-        </plugin>
-        <plugin>
-          <artifactId>maven-jar-plugin</artifactId>
-          <version>3.0.2</version>
-        </plugin>
-        <plugin>
-          <artifactId>maven-install-plugin</artifactId>
-          <version>2.5.2</version>
-        </plugin>
-        <plugin>
-          <artifactId>maven-deploy-plugin</artifactId>
-          <version>2.8.2</version>
-        </plugin>
-        <!-- site lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#site_Lifecycle -->
-        <plugin>
-          <artifactId>maven-site-plugin</artifactId>
-          <version>3.7.1</version>
-        </plugin>
-        <plugin>
-          <artifactId>maven-project-info-reports-plugin</artifactId>
-          <version>3.0.0</version>
-        </plugin>
       </plugins>
     </pluginManagement>
   </build>
diff --git a/src/main/java/com/thinker/App.java b/src/main/java/com/thinker/App.java
index 51c286c..e469bfc 100644
--- a/src/main/java/com/thinker/App.java
+++ b/src/main/java/com/thinker/App.java
@@ -26,7 +26,7 @@ public class App {
     }
 
     public static void main(String[] args) throws Exception {
-        System.out.println("Hello World!");
+        System.out.println("H   ello World!");
         if (args.length != 2) {
             System.err.println("USAGE:\nSocketTextStreamWordCount <hostname> <port>");
             return;