Overview
KNIME Big Data Extensions integrate Apache Spark and the Apache Hadoop ecosystem with KNIME Analytics Platform.
This guide is aimed at IT professionals who need to integrate KNIME Analytics Platform with an existing Hadoop/Spark environment.
The steps in this guide are required so that users of KNIME Analytics Platform run Spark workflows. Note that running Spark workflows on KNIME Server requires additional steps outlined in Secured Cluster Connection Guide for KNIME Server.
KNIME Extension for Apache Spark requires Apache Livy as REST service to be installed on an edge/frontend node of the cluster. See the requirements in the compatibility lists below and howto install Livy.
General Compatibility
KNIME Extension for Apache Spark is compatible with
-
Spark 2.x - 3.0
-
Livy 0.4 - 0.7
Cloudera CDP Compatibility
KNIME Extension for Apache Spark is compatible with
-
Spark 2.4 as included in CDP 7
-
Spark 3.0 on CDP 7 as provided by Cloudera CDS
Cloudera CDH Compatibility
KNIME Extension for Apache Spark is compatible with
-
Spark 2.x on CDH 5 as provided by Cloudera CDS
-
Spark 2.x as included in CDH 6
| Cloudera CDH 5/6 does not include Livy, therefore KNIME provides CSDs/parcels for Livy (see Cloudera CDH). |
Cloudera HDP Compatibility
KNIME Extension for Apache Spark is compatible with
-
Spark 2.x as included in HDP 2.6.3 - 2.6.5
-
Spark 2.x as included in HDP 3.0.0 - 3.1.5
Amazon EMR Compatibility
KNIME Extension for Apache Spark is compatible with
-
EMR 5.9+ with Spark 2.x and Livy 0.4 - 0.7
-
EMR 6.x with Spark 3.0 and Livy 0.6 - 0.7
Apache Livy setup
Cloudera CDP
Cloudera Runtime 7.0 - 7.1 includes Spark 2.4 and Livy as Service. Cloudera povides Spark 3.0 as a Custom Service Descriptor that can coexists with the included Spark version. See Installing CDS 3.0 Powered by Apache Spark in the Cloudera documentation for more information. Note that Livy in the Spark 3.0 CSD uses 28998 instead of the usual 8998 as default port.
| If you plan to run Spark workflows on KNIME Server: Please consult the Secured Cluster Connection Guide for KNIME Server to allow KNIME Server to impersonate users. |
Cloudera CDH
For Cloudera CDH, KNIME provides a CSD and parcel so that Livy can be installed as an add-on service.
The current version of Livy for CDH provided by KNIME is 0.5.0.knime3.
| The following steps describe how to install Livy as managed service through Cloudera Manager using a parcel. If in doubt, please also consider the official Cloudera documentation on handling parcels. |
Prerequisites
-
A cluster with CDH 5.8 and newer, or CDH 6.0 and newer
-
Only On CDH 5: Spark 2.2 or higher as an add-on service (provided by Cloudera CDS)
-
-
Root shell access (e.g. via SSH) on the machine where Cloudera Manager is installed.
-
Full administrative access on the Cloudera Manager WebUI.
Installation steps
In a root shell on the machine where Cloudera Manager is installed:
-
Download a matching CSD from CSDs for Cloudera CDH to
/opt/cloudera/csd/on the machine, where Cloudera Manager is installed. -
Only if Cloudera Manager cannot access the public internet: Download/copy the matching
.parceland.sha1file from Parcels for Cloudera CDH to/opt/cloudera/parcel-repo. -
Restart Cloudera Manager from the command line, for example with:
systemctl restart cloudera-scm-server
In the Cloudera Manager WebUI:
-
Navigate to the Parcel manager and locate the
LIVYparcel. -
Download (unless already done manually), Distribute and Activate the
LIVYparcel. -
Add the Livy Service to your cluster (see the official Cloudera documentation on adding services).
-
Navigate to the HDFS service configuration and add the following settings to the Cluster-wide Advanced Configuration Snippet (Safety Valve) for core-site.xml:
-
hadoop.proxyuser.livy.hosts=* -
hadoop.proxyuser.livy.groups=*
-
-
If your cluster is using HDFS Transparent Encryption: Navigate to the KMS service configuration and add the following settings to the Key Management Server Advanced Configuration Snippet (Safety Valve) for kms-site.xml:
-
hadoop.kms.proxyuser.livy.hosts=* -
hadoop.kms.proxyuser.livy.groups=*
-
-
If you plan to run Spark workflows on KNIME Server: Please consult the Secured Cluster Connection Guide for KNIME Server to allow KNIME Server to impersonate users.
-
Restart all services affected by your configuration changes.
Cloudera HDP
HDP already includes compatible versions of Apache Livy and Spark 2 (see Cloudera HDP Compatibility). Please follow the respective Hortonworks documentation to install Spark with the Livy for Spark2 Server component:
| KNIME Extension for Apache Spark only supports Livy for Spark2 Server which uses Spark 2. The Livy for Spark Server component is not supported, since it is based on Spark 1. |
Amazon EMR
Amazon EMR already includes compatible versions of Apache Livy and Spark 2 (see Amazon EMR Compatibility), simply make sure to select Livy in the software configuration of your cluster.
Downloads
Apache Livy downloads
CSDs for Cloudera CDH
Parcels for Cloudera CDH
Download links for CDH 5:
RHEL/CentOS |
|||
SLES |
|||
Ubuntu |
|||
Debian |
Download links for CDH 6
RHEL/CentOS |
|||
SLES |
|||
Ubuntu |
|||
Debian |