varOne give four dimensions for user to monitor spark applications,
The RESTful APIs for each dimension described in the following:
To get the all spark applications metrics by cluster.
Information
Description
metrics(optional)
Use , to separate each metrics. All of the available metrics at the bottom of this docs
period(require)
Assign the time period data of metrics
To get all node name in cluster, This method use YARN API to get the nodes information.
> GET /rest/nodes/:node_name
To get the all spark applications metrics per node.
Information
Description
node_name(require)
Assign a node which you want to monitor
metrics(optional)
Use , to separate each metrics. All of the available metrics at the bottom of this docs
period(require)
Assign the time period data of metrics
Fetch all running spark applications
> GET /rest/job/:application_id
Get the metrics of a specified application
Information
Description
application_id(require)
Assign a application id which you want to monitor
metrics(optional)
Use , to separate each metrics. All of the available metrics at the bottom of this docs
period(require)
Assign the time period data of metrics
Get all of the history applications, this method find these applications based on the records of event logs.
> GET /rest/history/:application_id/jobs
Get all of the jobs of a specified application.
Information
Description
application_id(require)
Assign a application id which you want to monitor
> GET /rest/history/:application_id/:job_id/stages
Get all of the stages of a specified application and job.
Information
Description
application_id(require)
Assign a application id which you want to monitor
job_id(require)
Assign a job id which you want to monitor
> GET /rest/history/:application_id/:job_id/:stage_id
Get all of the detail analysis of a specified application and job and stage.
Information
Description
application_id(require)
Assign a application id which you want to monitor
job_id(require)
Assign a job id which you want to monitor
stage_id(require)
Assign a stage id which you want to monitor
EXEC_FS_LOCAL_LARGEREAD_OPS
EXEC_FS_LOCAL_READ_BYTES
EXEC_FS_LOCAL_READ_OPS
EXEC_FS_LOCAL_WRITE_BYTES
EXEC_FS_LOCAL_WRITE_OPS
EXEC_FS_HDFS_LARGEREAD_OPS
EXEC_FS_HDFS_READ_BYTES
EXEC_FS_HDFS_READ_OPS
EXEC_FS_HDFS_WRITE_BYTES
EXEC_FS_HDFS_WRITE_OPS
EXEC_THREADPOOL_ACTIVETASK
EXEC_THREADPOOL_COMPLETETASK
EXEC_THREADPOOL_CURRPOOL_SIZE
EXEC_THREADPOOL_MAXPOOL_SIZE
JVM_HEAP_COMMITED
JVM_HEAP_INIT
JVM_HEAP_MAX
JVM_HEAP_USAGE
JVM_HEAP_USED
JVM_NON_HEAP_COMMITED
JVM_NON_HEAP_INIT
JVM_NON_HEAP_MAX
JVM_NON_HEAP_USAGE
JVM_NON_HEAP_USED
JVM_POOLS_CODE_CACHE_USAGE
JVM_POOLS_PS_EDEN_SPACE_USAGE
JVM_POOLS_PS_OLD_GEN_USAGE
JVM_POOLS_PS_PERM_GEN_USAGE
JVM_POOLS_PS_SURVIVOR_SPACE_USAGE
JVM_PS_MARKSWEEP_COUNT
JVM_PS_MARKSWEEP_TIME
JVM_PS_SCAVENGE_COUNT
JVM_PS_SCAVENGE_TIME