vking34/flink-labs

Flink Labs

Create project tempalte

mvn archetype:generate                            \
  -DarchetypeGroupId=org.apache.flink              \
  -DarchetypeArtifactId=flink-quickstart-java      \
  -DarchetypeVersion=1.13.0                        \
  -DgroupId=com.example                            \
  -DartifactId=my-flink-project                    \
  -Dversion=0.1                                    \
  -Dpackage=com.example.flink

Local Develop

• Add local runtime

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-runtime-web</artifactId>
    <version>${flink.version}</version>
</dependency>

• Change scope from provided to compile of dependencies:
  • flink-streaming-java
  • flink-clients
  • flink-java

Build

• Prerequisites

  • Java 8
  • Maven 3.2.5+
  • Change scope to provided:
    • flink-streaming-java
    • flink-clients
    • flink-java
  • Add dependency:

         <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.30</version>
        </dependency>
    

• Build

mvn clean package -Dmaven.test.skip=true