📋
Flink on Zeppelin
  • Setup Zeppelin
  • Main Features
  • Flink on Zeppelin Architecture
  • Execution mode
    • local mode
    • remote mode
    • yarn mode
    • yarn-application mode
  • Languages
    • Scala
    • PyFlink
    • SQL
  • Hive Integration
  • Interpreter binding mode
  • Configure Flink Interpreter
  • Third party dependencies
  • UDF
  • Checkpoint & Savepoint
  • Recovery
  • Flink Sql Cookbook
  • FAQ
Powered by GitBook
On this page
  • Global Setting
  • Note Level Setting
  • Community

Was this helpful?

Configure Flink Interpreter

PreviousInterpreter binding modeNextThird party dependencies

Last updated 3 years ago

Was this helpful?

There're 2 approaches to configure flink interpreter

  • Global setting in interpreter page

  • Note level setting

Global Setting

The setting in interpreter page is global, any change in interpreter page would affect all the notes. So it is suitable to configure global setting such as FLINK_HOME，HADOOP_CONF_DIR, HIVE_CONF_DIR, zeppelin.pyflink.python

Note Level Setting

Note level setting only works when the interpreter binding mode is isolated per note. Usually you put the note level setting in the first paragraph via %flink.conf

It is suitable to customize flink interpreter via note level setting such as flink.execution.packages, flink.udf.jars, flink.yarn.appName. Note level setting takes precedence over the global setting in interpreter page. e.g. You can set FLINK_HOME in %flink.conf to override that in interpreter setting page. Here's one simple example.

Community

Join Zeppelin community to discuss with others

Community
Logo