# initcap-flink

**Repository Path**: initcap/initcap-flink

## Basic Information

- **Project Name**: initcap-flink
- **Description**: flink案例
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-07-12
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# initial-flink

### Maven创建项目
#### Flink支持Maven直接构建模版项目，在终端使用一下命令:
```
mvn archetype:generate \
 -DarchetypeGroupId=org.apache.flink \
 -DarchetypeArtifactId=flink-quickstart-java \
 -DarchetypeVersion=1.10.0
```
#### 按照提示输入groupId、artifactId、version和package,生成如下结构
```
.
├── pom.xml
└── src
    └── main
        ├── java
        │   └── cn
        │       └── initcap
        │           ├── BatchJob.java
        │           └── StreamingJob.java
        └── resources
            └── log4j.properties
```
#### 该项目包含了两个类BatchJob和StreamingJob,另外还有一个log4j.properties配置文件，然后你就可以将该项目导入到IDEA了。

#### 现在可以执行mvn clean package就可以编译该项目，编译成功后在target目录下会生成一个Job的Jar包，但是这个Job还不能执行，因为StreamingJob这个类中的main方法里面只是简单的创建了StreamExecutionEnvironment环境，然后就执行execute方法，在Flink中是不算一个可执行的Job的，因此如果你提交到Flink UI 上也会报错；

### IDEA创建项目
#### 一般我们项目可能是由多个Job组成，并且代码也都是在同一个工程下面进行管理，上面那种适合单个Job执行，但如果多人合作的时候还是得在同一个工程下面进行项目创建，每个Flink Job一个module, 例如当前这个工程initcap-flink-core,我们执行mvn clean package后，每个子工程jar都可以提交到flink ui运行