main.yml

---
flink_version: "1.2.0"
# Possible choices: 1, 2, 24, 26, 27
flink_hadoop_version: "2"
flink_scala_version: "2.10"
flink_tmp_unpack_dir: "/tmp/flink-{{flink_version}}"
flink_filename: "flink-{{flink_version}}-bin-hadoop{{flink_hadoop_version}}-scala_{{flink_scala_version}}.tgz"
flink_install_chdir: "/opt"
flink_install_dir: "{{flink_install_chdir}}/flink"
flink_install_log4j_properties: "{{flink_install_dir}}/conf/log4j.properties"
# Set this directory to download and cache tarball onto local machine,
# for when the network connection between local and host is faster
# than between host and internet, and if role will be run for several
# hosts.
# flink_local_download_cache: .
flink_url_base: "http://archive.apache.org/dist/flink/"
flink_url: "{{flink_url_base}}/flink-{{flink_version}}/{{flink_filename}}"
flink_is_master: True
flink_start_stop_script: "{%if flink_is_master%}jobmanager{%else%}taskmanager{%endif%}"
flink_start_args: "start{%if flink_is_master%} cluster{%endif%}"
flink_stop_args: "stop"
flink_jobmanager_rpc_address: localhost
flink_jobmanager_rpc_port: 6123
flink_slaves: ['localhost']
flink_local_key_pattern: id_rsa.apache-flink
# This affects logging for both user code and Flink
flink_log4j_rootlogger: "INFO, file"
# The following lines keep the log level of common
# libraries/connectors on log level INFO. The root logger does not
# override this. You have to manually change the log levels here.
flink_log4j_logger_akka: INFO
flink_log4j_logger_org_apache_kafka: INFO
flink_log4j_logger_org_apache_hadoop: INFO
flink_log4j_logger_org_apache_zookeeper: INFO

# Log all infos in the given file
flink_log4j_appender_file: "org.apache.log4j.FileAppender"
flink_log4j_appender_file_file: "${log.file}"
flink_log4j_appender_file_append: "false"
flink_log4j_appender_file_layout: "org.apache.log4j.PatternLayout"
flink_log4j_appender_file_layout_ConversionPattern: "%d{yyyy-MM-dd HH:mm:ss,SSS} %-5p %-60c %x - %m%n"

# Suppress the irrelevant (wrong) warnings from the Netty channel handler
flink_log4j_logger_org_jboss_netty_channel_DefaultChannelPipeline: "ERROR, file"

flink_log4j_extra: {}
# Add this key into this dictionary if you want to _only_ change Flink's
# logging.  Add other keys if you want other configuration lines added
#  "log4j.logger.org.apache.flink": "INFO"

flink_user: flink
flink_user_shell: "/bin/bash"
flink_init_script: "/etc/init.d/flink-init.sh"
flink_jobmanager_heap_mb: 256
flink_jobmanager_web_port: 8081
flink_parallelism_default: 1
flink_taskmanager_heap_mb: 512
flink_taskmanager_memory_preallocate: "false"
flink_taskmanager_number_of_task_slots: 1
flink_env_log_dir: /var/log/flink
flink_env_pid_dir: /var/run/flink
flink_pidfile: "{{flink_env_pid_dir}}/flink-{{flink_user}}-{{flink_start_stop_script}}.pid"
flink_other_config: {}