big-data/flink-test
1
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

demo

Browse Source
This commit is contained in:
zeek 2020-05-01 12:40:03 +08:00
parent 183f233cb2
commit 707c38af25
2 changed files with 26 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
pom.xml
View File

@ -20,17 +20,32 @@
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.flink</groupId> <groupId>org.apache.flink</groupId>
<artifactId>flink-scala_2.11</artifactId> <artifactId>flink-java</artifactId>
<version>1.7.0</version> <version>1.10.0</version>
</dependency> </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> <dependency>
<groupId>org.apache.flink</groupId> <groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-scala_2.11</artifactId> <artifactId>statefun-sdk</artifactId>
<version>1.7.0</version> <version>2.0.0</version>
</dependency> </dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>statefun-flink-harness</artifactId>
<version>2.0.0</version>
</dependency>
<dependency> <dependency>
<groupId>junit</groupId> <groupId>junit</groupId>
@ -80,45 +95,6 @@
</executions> </executions>
</plugin> </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> </plugins>
</pluginManagement> </pluginManagement>
</build> </build>

2
src/main/java/com/thinker/App.java
View File

@ -26,7 +26,7 @@ public class App {
} }
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
System.out.println("Hello World!"); System.out.println("H ello World!");
if (args.length != 2) { if (args.length != 2) {
System.err.println("USAGE:\nSocketTextStreamWordCount <hostname> <port>"); System.err.println("USAGE:\nSocketTextStreamWordCount <hostname> <port>");
return; return;