Metriche Spark

Per impostazione predefinita, Dataproc Serverless abilita la raccolta metriche Spark disponibili, a meno che non utilizzi Proprietà di raccolta delle metriche di Spark per disabilitare o eseguire l'override della raccolta di una o più metriche Spark.

Nota: consulta anche Proprietà Spark, che descrive proprietà aggiuntive che puoi impostare quando invii un Carico di lavoro batch Spark serverless di Dataproc.

Proprietà di raccolta delle metriche Spark

Puoi utilizzare le proprietà elencate in questa sezione per disattivare o eseguire l'override della raccolta di uno o più metriche Spark disponibili.

Proprietà	Descrizione
spark.dataproc.driver.metrics	Utilizza questa opzione per disattivare o eseguire l'override delle metriche del driver di Spark.
spark.dataproc.executor.metrics	Utilizza questa opzione per disattivare o eseguire l'override delle metriche esecutore di Spark.
spark.dataproc.system.metrics	Utilizza questa opzione per disattivare le metriche di sistema di Spark.

Esempi di gcloud CLI:

• Disabilita la raccolta delle metriche del driver Spark:

  gcloud dataproc batches submit spark \
      --properties spark.dataproc.driver.metrics="" \
      --region=region \
      other args ...
  

• Esegui l'override della raccolta delle metriche del driver predefinita di Spark per solo raccogliere BlockManager:disk.diskSpaceUsed_MB e DAGScheduler:stage.failedStages metriche:

  gcloud dataproc batches submit spark \
      --properties=^~^spark.dataproc.driver.metrics="BlockManager:disk.diskSpaceUsed_MB,DAGScheduler:stage.failedStages" \
      --region=region \
      other args ...
  

Nota: poiché la virgola (,) viene utilizzata per separare due valori associati a spark.dataproc.driver.metrics nell'esempio precedente, il carattere ~ è specificato come delimitatore di proprietà invece del delimitatore di virgola predefinito. Per ulteriori informazioni, vedi formattazione delle proprietà del cluster .

Metriche Spark disponibili

Dataproc Serverless raccoglie le metriche Spark elencate in questa sezione a meno che non utilizzi Proprietà di raccolta delle metriche di Spark per disattivare o eseguire l'override della raccolta.

Nota: le metriche vengono raccolte nel seguente formato:

custom.googleapis.com/METRIC_EXPLORER_NAME.

Metriche del driver Spark

Metrica	Nome Metrics Explorer
BlockManager:disk.diskSpaceUsed_MB	spark/driver/BlockManager/disk/diskSpaceUsed_MB
BlockManager:memory.maxMem_MB	spark/driver/BlockManager/memory/maxMem_MB
BlockManager:memory.memUsed_MB	spark/driver/BlockManager/memory/memUsed_MB
DAGScheduler:job.activeJobs	spark/driver/DAGScheduler/job/activeJobs
DAGScheduler:job.allJobs	spark/driver/DAGScheduler/job/allJobs
DAGScheduler:messageProcessingTime	spark/driver/DAGScheduler/messageProcessingTime
DAGScheduler:stage.failedStages	spark/driver/DAGScheduler/stage/failedStages
DAGScheduler:stage.runningStages	spark/driver/DAGScheduler/stage/runningStages
DAGScheduler:stage.waitingStages	spark/driver/DAGScheduler/stage/waitingStages

Metriche esecutore Spark

Metrica	Nome Metrics Explorer
ExecutorAllocationManager:executors.numberExecutorsDecommissionUnfinished	spark/driver/ExecutorAllocationManager/executors/numberExecutorsDecommissionUnfinished
ExecutorAllocationManager:executors.numberExecutorsExitedUnexpectedly	spark/driver/ExecutorAllocationManager/executors/numberExecutorsExitedUnexpectedly
ExecutorAllocationManager:executors.numberExecutorsGracefullyDecommissioned	spark/driver/ExecutorAllocationManager/executors/numberExecutorsGracefullyDecommissioned
ExecutorAllocationManager:executors.numberExecutorsKilledByDriver	spark/driver/ExecutorAllocationManager/executors/numberExecutorsKilledByDriver
LiveListenerBus:queue.executorManagement.listenerProcessingTime	spark/driver/LiveListenerBus/queue/executorManagement/listenerProcessingTime
executor:bytesRead	spark/esecutore/bytesRead
executor:bytesWritten	spark/esecutore/byte scritti
executor:cpuTime	spark/executor/cpuTime
executor:diskBytesSpilled	spark/executor/diskBytesSpilled
executor:jvmGCTime	spark/executor/jvmGCTime
executor:memoryBytesSpilled	spark/executor/memoryBytesSpilled
executor:recordsRead	spark/executor/recordsRead
executor:recordsWritten	spark/esecutore/record
executor:runTime	spark/executor/runTime
executor:shuffleFetchWaitTime	spark/executor/shuffleFetchWaitTime
executor:shuffleRecordsRead	spark/executor/shuffleRecordsRead
executor:shuffleRecordsWritten	spark/executor/shuffleRecordsWritten
executor:shuffleRemoteBytesReadToDisk	spark/executor/shuffleRemoteBytesReadToDisk
executor:shuffleWriteTime	spark/executor/shuffleWriteTime
executor:succeededTasks	spark/executor/succeededTasks
ExecutorMetrics:MajorGCTime	spark/executor/ExecutorMetrics/MajorGCTime
ExecutorMetrics:MinorGCTime	spark/executor/ExecutorMetrics/MinorGCTime

Metriche di sistema

Metrica	Nome Esplora metriche
agent:uptime	agente/tempo di attività
cpu:utilizzo	cpu/utilization
disk:byte_utilizzati	disco/byte_utilizzati
disk:percent_used	disco/percentuale_utilizzato
memoria:byte_utilizzata	memoria/byte_utilizzati
memory:percent_used	memoria/percentuale_utilizzata
network:tcp_connections	network/tcp_connections

Visualizza metriche Spark

Per visualizzare le metriche batch, fai clic su un ID batch nella nella pagina Batch. nella console Google Cloud per aprire la pagina Dettagli del batch, che mostra un grafico delle metriche per il carico di lavoro batch nella scheda Monitoraggio.

Consulta Cloud Monitoring di Dataproc per ulteriori informazioni su come visualizzare le metriche raccolte.