Building Flink from Source #
This page covers how to build Flink 1.16.2 from sources.
Build Flink #
In addition you need Maven 3 and a JDK (Java Development Kit). Flink requires at least Java 11 to build.
NOTE: Maven 3.3.x can build Flink, but will not properly shade away certain dependencies. Maven 3.2.5 creates the libraries properly.
To clone from git, enter:
git clone https://github.com/apache/flink.git
The simplest way of building Flink is by running:
mvn clean install -DskipTests
This instructs Maven (
mvn) to first remove all existing builds (
clean) and then create a new Flink binary (
To speed up the build you can:
- skip tests by using ’ -DskipTests'
- skip QA plugins and javadoc generation by using the
- skip the WebUI compilation by using the
- use Maven’s parallel build feature, e.g., ‘mvn package -T 1C’ will attempt to build 1 module for each CPU core in parallel.
Parallel builds may deadlock due to a bug in the maven-shade-plugin. It is recommended to only use it as a 2 steps process, where you first run
mvn validate/test-compile/testin parallel, and then run
mvn package/verify/installwith a single thread.
The build script will be:
mvn clean install -DskipTests -Dfast -Pskip-webui-build -T 1C
skip-webui-build profiles have a significant impact on the build time, particularly on slower storage devices, due to them reading/writing many small files.
Build PyFlink #
If you want to build a PyFlink package that can be used for pip installation, you need to build the Flink project first, as described in Build Flink.
Python version(3.6, 3.7, 3.8 or 3.9) is required
$ python --version # the version printed here must be 3.6, 3.7, 3.8 or 3.9
Build PyFlink with Cython extension support (optional)
To build PyFlink with Cython extension support, you’ll need a C compiler. It’s a little different on how to install the C compiler on different operating systems:
Linux Linux operating systems usually come with GCC pre-installed. Otherwise, you need to install it manually. For example, you can install it with command
sudo apt-get install build-essentialOn Ubuntu or Debian.
Mac OS X To install GCC on Mac OS X, you need to download and install “Command Line Tools for Xcode”, which is available in Apple’s developer page.
You also need to install the dependencies with following command:
$ python -m pip install -r flink-python/dev/dev-requirements.txt
Then go to the root directory of flink source code and run this command to build the sdist package and wheel package of
cd flink-python; python setup.py sdist bdist_wheel; cd apache-flink-libraries; python setup.py sdist; cd ..;
The sdist package of
apache-flink-libraries will be found under
./flink-python/apache-flink-libraries/dist/. It could be installed as following:
python -m pip install apache-flink-libraries/dist/*.tar.gz
The sdist and wheel packages of
apache-flink will be found under
./flink-python/dist/. Either of them could be used for installation, such as:
python -m pip install dist/*.whl
Dependency Shading #
Flink shades away some of the libraries it uses, in order to avoid version clashes with user programs that use different versions of these libraries. Among the shaded libraries are Google Guava, Asm, Apache Curator, Apache HTTP Components, Netty, and others.
The dependency shading mechanism was recently changed in Maven and requires users to build Flink slightly differently, depending on their Maven version:
Maven and 3.2.x
It is sufficient to call
mvn clean install -DskipTests in the root directory of Flink code base.
Maven 3.3.x The build has to be done in two steps: First in the base directory, then in shaded modules, such as the distribution and the filesystems:
# build overall project mvn clean install -DskipTests # build shaded modules used in dist again, for example: cd flink-filesystems/flink-s3-fs-presto/ mvn clean install -DskipTests # ... and other modules # build dist again to include shaded modules cd flink-dist mvn clean install
Note: To check your Maven version, run
Note: We recommend using the latest Maven 3.2.x version for building production-grade Flink distributions, as this is the version the Flink developers are using for the official releases and testing.
Scala Versions #
Users that purely use the Java APIs and libraries can ignore this section.
Flink has APIs, libraries, and runtime modules written in Scala. Users of the Scala API and libraries may have to match the Scala version of Flink with the Scala version of their projects (because Scala is not strictly backwards compatible).
Since version 1.15 Flink dropped the support of Scala 2.11 and it will use Scala 2.12 to build by default.
To build against a specific binary Scala version you can use:
mvn clean install -DskipTests -Dscala-2.12 -Dscala.version=<scala version>
Encrypted File Systems #
If your home directory is encrypted you might encounter a
java.io.IOException: File name too long exception. Some encrypted file systems, like encfs used by Ubuntu, do not allow long filenames, which is the cause of this error.
The workaround is to add:
<args> <arg>-Xmax-classfile-name</arg> <arg>128</arg> </args>
in the compiler configuration of the
pom.xml file of the module causing the error. For example, if the error appears in the
flink-yarn module, the above code should be added under the
<configuration> tag of
scala-maven-plugin. See this issue for more information.