Jeff Zhang zjffdu

## flink_interpreter.tsv

          
            Name
            Class
            Description

            
              %flink
              FlinkInterpreter
              Creates ExecutionEnvironment/StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironment and provides a Scala environment

            
              %flink.pyflink
              PyFlinkInterpreter
              Provides a python environment

            
              %flink.ipyflink
              IPyFlinkInterpreter
              Provides an ipython environment

            
              %flink.ssql
              FlinkStreamSqlInterpreter
              Provides a stream sql environment

            
              %flink.bsql
              FlinkBatchSqlInterpreter
              Provides a batch sql environment

## flink_properties.tsv

          
            Property
            Default
            Description

            
              FLINK_HOME
              
              Location of flink installation. It is must be specified, otherwise you can not use flink in Zeppelin

            
              HADOOP_CONF_DIR
              
              location of hadoop conf, this is must be set if running in yarn mode

            
              HIVE_CONF_DIR
              
              location of hive conf, this is must be set if you want to connect to hive metastore

            
              flink.execution.mode
              local
              Execution mode of flink, e.g. local | yarn | remote

            
              flink.execution.remote.host
              
              jobmanager hostname if it is remote mode

            
              flink.execution.remote.port
              
              jobmanager port if it is remote mode

            
              flink.jm.memory
              1024
              Total number of memory(mb) of JobManager

            
              flink.tm.memory
              1024
              Total number of memory(mb) of TaskManager

            
              flink.tm.slot
              1
              Number of slot per TaskManager
Name	Class	Description
%flink	FlinkInterpreter	Creates ExecutionEnvironment/StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironment and provides a Scala environment
%flink.pyflink	PyFlinkInterpreter	Provides a python environment
%flink.ipyflink	IPyFlinkInterpreter	Provides an ipython environment
%flink.ssql	FlinkStreamSqlInterpreter	Provides a stream sql environment
%flink.bsql	FlinkBatchSqlInterpreter	Provides a batch sql environment
Property	Default	Description
FLINK_HOME		Location of flink installation. It is must be specified, otherwise you can not use flink in Zeppelin
HADOOP_CONF_DIR		location of hadoop conf, this is must be set if running in yarn mode
HIVE_CONF_DIR		location of hive conf, this is must be set if you want to connect to hive metastore
flink.execution.mode	local	Execution mode of flink, e.g. local \| yarn \| remote
flink.execution.remote.host		jobmanager hostname if it is remote mode
flink.execution.remote.port		jobmanager port if it is remote mode
flink.jm.memory	1024	Total number of memory(mb) of JobManager
flink.tm.memory	1024	Total number of memory(mb) of TaskManager
flink.tm.slot	1	Number of slot per TaskManager