LivySessionController

Description:

Manages pool of Spark sessions over HTTP

Tags:

Livy, REST, Spark, http

Properties:

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
Livy Hostlivy-cs-livy-hostThe hostname (or IP address) of the Livy server.
Supports Expression Language: true (will be evaluated using variable registry only)
Livy Portlivy-cs-livy-port8998The port number for the Livy server.
Supports Expression Language: true (will be evaluated using variable registry only)
Session Pool Sizelivy-cs-session-pool-size2Number of sessions to keep open
Supports Expression Language: true (will be evaluated using variable registry only)
Session Typelivy-cs-session-kindspark
  • spark
  • pyspark
  • pyspark3
  • sparkr
The type of Spark session to start (spark, pyspark, pyspark3, sparkr, e.g.)
Session Manager Status Intervallivy-cs-session-manager-status-interval2 secThe amount of time to wait between requesting session information updates.
Supports Expression Language: true (will be evaluated using variable registry only)
SSL Context ServiceSSL Context ServiceController Service API:
SSLContextService
Implementations: StandardRestrictedSSLContextService
StandardSSLContextService
The SSL Context Service used to provide client certificate information for TLS/SSL (https) connections.
Connection TimeoutConnection Timeout5 secsMax wait time for connection to remote service.
Session JARslivy-cs-session-jarsJARs to be used in the Spark session.

This property expects a comma-separated list of file resources.

Supports Expression Language: true (will be evaluated using variable registry only)
Session Fileslivy-cs-session-filesFiles to be used in the Spark session.

This property expects a comma-separated list of file resources.

Supports Expression Language: true (will be evaluated using variable registry only)
Kerberos Credentials Servicekerberos-credentials-serviceController Service API:
KerberosCredentialsService
Implementation: KeytabCredentialsService
Specifies the Kerberos Credentials Controller Service that should be used for authenticating with Kerberos

State management:

This component does not store state.

Restricted:

This component is not restricted.

System Resource Considerations:

None specified.