Configuring Flink
Desribes how to configure Flink.
Flink Overview
The default configuration directory is
in:
/opt/mapr/flink/flink-<version>/confThis path can be
changed with FLINK_CONF_DIR environment variable.See the following Apache Flink documentation on configuring Flink:
- Configuration for details on
configuration directory in general, and the main configuration file is
config.yaml. - How to use logging for details on different logging files.
Default Configuration
Data Fabric Ecosystem Pack applies the default configuration on top of
Apache Flink default configuration, for example:
- TLS/SSL is enabled by default. See Security in Flink for details.
Using MapR-FS as a checkpoint storage
Flink on Data Fabric supports storing checkpoint data in
MapR-FS. You can specify a
maprfs:// URL in
execution.checkpointing.dir as
follows:execution:
checkpointing:
dir: maprfs:///user/<username>/flink/checkpointsIntegrating Flink with ZooKeeper for High Availability
Flink on Data Fabric supports integration with ZooKeeper
for high availability. You can specify a Data Fabric's
ZooKeeper quorum in
high-availability.zookeeper.quorum as well as a
maprfs:// URL in high-availability.storageDir
as follows:high-availability:
storageDir: maprfs:///user/mapruser1/flink/ha
zookeeper:
quorum: <host name>:5181