haazi.blogg.se

We are going only to cover my favourite Java IDE: IntelliJ IDEA. We are going to focus only on StreamingJob.java. ├── pom.xml └── src └── main ├── java │ └── galiglobal │ └── flink │ ├── BatchJob.java │ └── StreamingJob.java └── resources └── log4j2.properties The structure of the project is quite simple: DarchetypeArtifactId=flink-quickstart-java

To bootstrap the project, just execute the following Maven command: Sh $FLINK_HOME/bin/stop-cluster.sh Bootstrap a Flink job We aren't going to need it initially so it's better to stop it: You can access the Flink Web Dashboard in your browser. Note: it's a good idea to create a variable $FLINK_HOME pointing to the Flink folder. This is straightforward, just go to the Flink download page and download it: The source code is available in this GitHub repository. If you are already an experienced Flink developer, there are some tricks you may find useful: access to JMX metrics, profiling, etc.

If Flink is something new for you, it's an easy guide to follow. In this article, I summarize some of the notes I've been writing since I started with Flink. Even if there is a good Getting Started or a great (and free) Hands-on Training, there are always questions about how to start, how to debug problems or how to launch the project in your IDE. As any of those framework, start to work with it can be a challenge. Flink setup for development (and some IntelliJ Idea cool tricks)Īpache Flink is an open-source, unified stream-processing and batch-processing framework.