Memorizzazione in cache del cluster

Quando abiliti la memorizzazione nella cache del cluster Managed Service for Apache Spark, il cluster memorizza nella cache i dati Cloud Storage a cui accedono di frequente i job Spark.

Vantaggi

  • Prestazioni migliorate:la memorizzazione nella cache può migliorare le prestazioni dei job riducendo il tempo trascorso a recuperare i dati dallo spazio di archiviazione.
  • Costi di archiviazione ridotti:poiché i dati attivi vengono memorizzati nella cache sul disco locale, vengono effettuate meno chiamate API all'archiviazione per recuperare i dati.
  • Applicabilità del job Spark: quando la memorizzazione nella cache del cluster è abilitata su un cluster, si applica a tutti i job Spark eseguiti sul cluster, indipendentemente dal fatto che siano inviati a Managed Service for Apache Spark o eseguiti in modo indipendente sul cluster.

Limitazioni e requisiti

Abilita la memorizzazione nella cache del cluster

Puoi attivare la memorizzazione nella cache del cluster quando crei un cluster Managed Service for Apache Spark utilizzando la console Cloud de Confiance , Google Cloud CLI o l'API Dataproc.

ConsoleCloud de Confiance

  1. Apri la console Cloud de Confiance pagina Crea cluster.
  2. Fai clic su Configurazione aggiuntiva per espandere la sezione.
  3. Modifica Personalizzazione e altro.
  4. Nel riquadro che si apre, nella sezione Proprietà cluster, fai clic su + Aggiungi proprietà.
  5. Seleziona dataproc nell'elenco Prefisso, quindi aggiungi la chiave dataproc.cluster.caching.enabled e il valore true.

gcloud CLI

Esegui il comando gcloud dataproc clusters create localmente in una finestra del terminale o in Cloud Shell utilizzando la dataproc:dataproc.cluster.caching.enabled=true proprietà del cluster.

Esempio:

gcloud dataproc clusters create CLUSTER_NAME \
    --region=REGION \
    --properties dataproc:dataproc.cluster.caching.enabled=true \
    --num-master-local-ssds=2 \
    --master-local-ssd-interface=NVME \
    --num-worker-local-ssds=2 \
    --worker-local-ssd-interface=NVME \
    other args ...
  

API REST

Imposta SoftwareConfig.properties in modo da includere la proprietà del cluster "dataproc:dataproc.cluster.caching.enabled": "true" come parte di una richiesta clusters.create.