This topic describes how to create a Kubernetes-based cluster in the EMR console.
Prerequisites
-
The AliyunOSSFullAccess and AliyunDLFFullAccess policies have been granted. For more information, see Grant permissions to access OSS and DLF.
-
A Kubernetes cluster has been created. For more information, see Create an ACK dedicated cluster (discontinued) or Create an ACK managed cluster.
-
A node pool has been created. For more information, see Create and manage a node pool.
-
Object Storage Service (OSS) has been activated. For more information, see Activate OSS.
Procedure
-
Log in to the EMR on ACK console.
-
On the EMR on ACK page, click Create Cluster.
-
On the EMR on ACK page, configure the cluster parameters.
Parameter
Description
Region
The deployment region for the cluster. This cannot be changed after creation.
Cluster Type
The following cluster types are supported:
-
Shuffle Service: an EMR extension component that optimizes shuffle operations. It provides a remote shuffle service, enabling Spark jobs to run on nodes without local disks and efficiently supporting dynamic resources. This makes it highly suitable for Spark clusters in an ACK environment. For more information, see Celeborn.
ImportantWhen you create a Shuffle Service cluster, the instance specification of the dedicated node pool or nodes in the associated ACK cluster must be big data or local SSD. Otherwise, the RSS deployment fails.
NoteThis job optimizes storage management and prevents waste by removing invalid or redundant PVCs.
-
Presto: an in-memory distributed SQL engine for interactive queries.
It supports multiple data sources and is suitable for complex analysis of petabyte-scale data and cross-data-source queries.
-
Spark: A general-purpose, distributed big data processing engine for ETL, offline batch processing, and data modeling.
ImportantTo associate a Spark cluster with a Shuffle Service cluster, their major product versions must match. For example, a Spark cluster of version EMR-5.x-ack can be associated only with a Shuffle Service cluster of version EMR-5.x-ack.
-
Flink: a distributed processing engine for stateful computations over bounded and unbounded data streams. Flink on ACK is built on EMR on ACK and the community Flink Kubernetes Operator 1.0.1. By default, it uses the enterprise kernel from the official Flink team to provide an out-of-the-box Flink on Kubernetes experience.
Product Version
Defaults to the latest software version.
Component Version
Displays the components and their versions for the selected cluster type.
ACK cluster
Select an existing ACK cluster, or create a new one in the Container Service for Kubernetes (ACK) console.
Click Configure Dedicated Nodes to configure EMR-dedicated nodes. This process applies EMR-specific taints and labels to a node pool or to individual nodes, reserving them for exclusive use by EMR.
NoteWe recommend configuring dedicated nodes using a node pool. If no node pool is available, create one. For more information, see Create a node pool.
OSS bucket
Select an existing bucket, or create a new one in the Object Storage Service (OSS) console.
Cluster Name
Must be 1 to 64 characters long and can contain only Chinese characters, letters, digits, hyphens (-), and underscores (_).
-
-
Click create.
Cluster creation is complete when its status changes to Running.