创建一个Flink项目

Flink 环境搭建

下载链接&＃xff1a;https://archive.apache.org/dist/flink/flink-1.5.4/

直接下载bin包&＃xff1a;flink-1.5.4-bin-hadoop24-scala_2.11.tgz &＃xff0c;解压后启动flink&＃xff1a;

jimmy&＃64;jimmy-ThinkPad-T420s:~/Downloads/flink-1.5.4/bin$ ./start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host jimmy-ThinkPad-T420s.
Starting taskexecutor daemon on host jimmy-ThinkPad-T420s.


打开WEB&＃xff1a;http://127.0.0.1:8081

运行一个example

./bin/flink run ./examples/batch/WordCount.jar

immy&＃64;jimmy-ThinkPad-T420s:~/Downloads/flink-1.9.3$ ./bin/flink run ./examples/batch/WordCount.jar
Starting execution of program
Executing WordCount example with default input data set.
Use --input to specify file input.
Printing result to stdout. Use --output to specify output path.
(a,5)
(action,1)
(after,1)
(against,1)
(all,2)
(and,12)


注&＃xff1a;如果example运行不成功&＃xff0c;应该是jdk版本不匹配导致

mvn 产生一个flink项目框架

flink版本1.5.4

mvn archetype:generate -DarchetypeCatalog&＃61;internal -DarchetypeGroupId&＃61;org.apache.flink -DarchetypeArtifactId&＃61;flink-quickstart-java -DarchetypeVersion&＃61;1.5.4

F:\eclipse-workspace\flink>mvn archetype:generate -DarchetypeCatalog&＃61;internal -DarchetypeGroupId&＃61;org.apache.flink -DarchetypeArtifactId&＃61;flink-quickstart-java -DarchetypeVersion&＃61;1.5.4
[INFO] Scanning for projects...
[INFO]
[INFO] -------------------------------------
[INFO] Building Maven Stub Project (No POM) 1
[INFO] --------------------------------[ pom ]---------------------------------
[INFO]
[INFO] >>> maven-archetype-plugin:3.2.0:generate (default-cli) > generate-sources &＃64; standalone-pom >>>
[INFO]
[INFO] <<[INFO]
[INFO]
[INFO] --- maven-archetype-plugin:3.2.0:generate (default-cli) &＃64; standalone-pom ---
[INFO] Generating project in Interactive mode
[WARNING] Archetype not found in any catalog. Falling back to central repository.
[WARNING] Add a repository with id &＃39;archetype&＃39; in your settings.xml if archetype&＃39;s repository is elsewhere.
Define value for property &＃39;groupId&＃39;: com.company.test.flink
Define value for property &＃39;artifactId&＃39;: test-flink
Define value for property &＃39;version&＃39; 1.0-SNAPSHOT: :
Define value for property &＃39;package&＃39; com.company.test.flink: :
Confirm properties configuration:
groupId: com.company.test.flink
artifactId: test-flink
version: 1.0-SNAPSHOT
package: com.company.test.flinkY: :
[INFO] ----------------------------------------------------------------------------
[INFO] Using following parameters for creating project from Archetype: flink-quickstart-java:1.5.4
[INFO] ----------------------------------------------------------------------------
[INFO] Parameter: groupId, Value: com.company.test.flink
[INFO] Parameter: artifactId, Value: test-flink
[INFO] Parameter: version, Value: 1.0-SNAPSHOT
[INFO] Parameter: package, Value: com.company.test.flink
[INFO] Parameter: packageInPathFormat, Value: com/company/test/flink
[INFO] Parameter: package, Value: com.company.test.flink
[INFO] Parameter: version, Value: 1.0-SNAPSHOT
[INFO] Parameter: groupId, Value: com.company.test.flink
[INFO] Parameter: artifactId, Value: test-flink
[WARNING] CP Don&＃39;t override file F:\eclipse-workspace\flink\test-flink\src\main\resources
[INFO] Project created from Archetype in dir: F:\eclipse-workspace\flink\test-flink
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 28.866 s
[INFO] Finished at: 2020-09-24T17:06:45&＃43;08:00
[INFO] ------------------------------------------------------------------------F:\eclipse-workspace\flink>

Eclipse导入工程

将maven项目转换成eclipse项目&＃xff1a;mvn eclipse:eclipse

jimmy&＃64;jimmy-ThinkPad-T420s:~/eclipse-workspace/flink/test-flink$ mvn eclipse:eclipse
[INFO] Scanning for projects...
Downloading from central: https://repo.maven.apache.org/maven2/org/eclipse/m2e/lifecycle-mapping/1.0.0/lifecycle-mapping-1.0.0.pom
[WARNING] The POM for org.eclipse.m2e:lifecycle-mapping:jar:1.0.0 is missing, no dependency information available
Downloading from central: https://repo.maven.apache.org/maven2/org/eclipse/m2e/lifecycle-mapping/1.0.0/lifecycle-mapping-1.0.0.jar
[WARNING] Failed to retrieve plugin descriptor for org.eclipse.m2e:lifecycle-mapping:1.0.0: Plugin org.eclipse.m2e:lifecycle-mapping:1.0.0 or one of its dependencies could not be resolved: Could not find artifact org.eclipse.m2e:lifecycle-mapping:jar:1.0.0 in central (https://repo.maven.apache.org/maven2)
Downloading from central: https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-eclipse-plugin/maven-metadata.xml
Downloaded from central: https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-eclipse-plugin/maven-metadata.xml (741 B at 491 B/s)
Downloading from central: https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-eclipse-plugin/2.10/maven-eclipse-plugin-2.10.pom
Downloaded from central: https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-eclipse-plugin/2.10/maven-eclipse-plugin-2.10.pom (19 kB at 18 kB/s)
Downloading from central: https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-eclipse-plugin/2.10/maven-eclipse-plugin-2.10.jar
Downloaded from central: https://repo.maven.apache.org/maven2/org/apache/maven/plugins/maven-eclipse-plugin/2.10/maven-eclipse-plugin-2.10.jar (224 kB at 108 kB/s)
[INFO]
[INFO] -------------------------------------------
[INFO] Building Flink Quickstart Job 1.0-SNAPSHOT
[INFO] --------------------------------[ jar ]---------------------------------


file->import->maven->existing maven project