Estos contenidos se han traducido de forma automática para su comodidad, pero Huawei Cloud no garantiza la exactitud de estos. Para consultar los contenidos originales, acceda a la versión en inglés.
Actualización más reciente 2023-07-28 GMT+08:00

Consulta de información sobre un trabajo

Función

Esta API se utiliza para consultar información sobre un trabajo especificado en un clúster MRS.

Restricciones

Ninguna

Depuración

Puede depurar esta API a través de la autenticación automática en API Explorer. API Explorer puede generar automáticamente código SDK de ejemplo y proporcionar la depuración de código SDK de ejemplo.

URI

  • Formato

    GET /v2/{project_id}/clusters/{cluster_id}/job-executions/{job_execution_id}

  • Descripción de parámetro
    Tabla 1 Parámetros de URI

    Parámetro

    Obligatorio

    Tipo

    Descripción

    project_id

    String

    El ID del proyecto. Para obtener más información sobre cómo obtener el ID del proyecto, consulte Obtención de un ID de proyecto.

    cluster_id

    String

    El ID del clúster. Para obtener más información sobre cómo obtener el ID de clúster, consulte Obtención de un ID de clúster.

    job_execution_id

    String

    El ID de trabajo. Para obtener más información sobre cómo obtener el ID de trabajo, consulte Obtención de un ID de trabajo.

Parámetros de solicitud

Parámetro de solicitud

Ninguna

Parámetros de respuesta

Código de estado: 202

Tabla 2 Parámetro de respuesta

Parámetro

Tipo

Descripción

job_detail

JobQueryBean object

Detalles del trabajo. Para obtener más información sobre los parámetros, consulte Tabla 3.

Tabla 3 Parámetros de trabajo

Parámetro

Tipo

Descripción

job_id

String

El ID de trabajo.

user

String

El nombre del usuario que envía un trabajo.

job_name

String

El nombre del trabajo.

job_result

String

El resultado final de un trabajo. Valores posibles:

  • FAILED: indica que el trabajo no se puede ejecutar.
  • KILLED: indica que el trabajo se termina manualmente durante la ejecución.
  • UNDEFINED: indica que el trabajo se está ejecutando.
  • SUCCEEDED: indica que el trabajo se ha ejecutado correctamente.

job_state

String

El estado de ejecución del trabajo. Valores posibles:

  • FAILED: indica que el trabajo ha fallado.
  • KILLED: indica que el trabajo se ha terminado.
  • New: indica que se ha creado el trabajo.
  • NEW_SAVING: indica que el trabajo se ha creado y se está guardando.
  • SUBMITTED: indica que se ha enviado el trabajo.
  • ACCEPTED: indica que el trabajo es aceptado.
  • RUNNING: indica que el trabajo se está ejecutando.
  • FINISHED: indica que el trabajo se ha completado.

job_progress

Float

El progreso de la ejecución del trabajo.

job_type

String

El tipo de trabajo. Valores posibles:

  • MapReduce
  • SparkSubmit: seleccione este valor cuando invoca a una API para consultar trabajos de SparkPython.
  • HiveScript
  • HiveSql
  • DistCp: importa y exporta datos.
  • SparkScript
  • SparkSql
  • Flink

started_time

Long

La hora en que un trabajo comienza a ejecutarse, en milisegundos.

submitted_time

Long

La hora en que se envía un trabajo, en milisegundos.

finished_time

Long

La hora en que se completa la ejecución de un trabajo, en milisegundos.

elapsed_time

Long

Duración de la ejecución del trabajo, en milisegundos.

arguments

String

Ejecutar parámetros.

properties

String

El parámetro de configuración, que se utiliza para configurar los parámetros de -d. El valor puede contener un máximo de 2,048 caracteres. No se permiten caracteres especiales (;|&>'<$!\\). Este parámetro se puede dejar en blanco.

launcher_id

String

El ID de trabajo del lanzador.

app_id

String

El ID de trabajo real.

tracking_url

String

La URL para acceder a los registros. Actualmente, solo los trabajos de SparkSubmit admiten este parámetro. Este parámetro accede a la interfaz de usuario web de Yarn a través del EIP enlazado al clúster. Si el EIP no está vinculado del clúster en la consola de VPC, los datos de servicio de MRS no se actualizan de manera oportuna y el acceso falla. En este caso, puede vincular el EIP al clúster de nuevo para rectificar el error.

queue

String

El tipo de cola de recursos utilizada por un trabajo.

Código de estado: 500

Tabla 4 Parámetros de body de respuesta

Parámetro

Tipo

Descripción

error_code

String

El código de error.

error_msg

String

El mensaje de error.

Ejemplo

  • Solicitud de ejemplo

    Consulta de información sobre un trabajo

    GET https://{endpoint}/v2/{project_id}/clusters/{cluster_id}/job-executions/{job_execution_id}
  • Ejemplo de respuesta
    • Ejemplo de una respuesta exitosa
      {
          "job_detail": {
              "job_id": "431b135e-c090-489f-b1db-0abe3822b855",
              "user": "xxxx",
              "job_name": "pyspark1",
              "job_result": "SUCCEEDED",
              "job_state": "FINISHED",
              "job_progress": "100",
              "job_type": "SparkSubmit",
              "started_time": "1564626578817",
              "submitted_time": 1564626561541,
              "finished_time": 1564626664930,
              "elapsed_time": 86113,
              "queue": "default",
              "arguments": "[--class, org.apache.spark.examples.SparkPi, --driver-memory, 512MB, --num-executors, 1, --executor-cores, 1, --master, yarn-cluster, obs://obs-test/jobs/spark/spark-examples_2.11-2.1.0.jar, 10000]",
              "launcher_id": "application_1564622673393_0006",
              "app_id": "application_1564622673393_0007",
              "properties": "{}"
          }
      }
    • Ejemplo de una respuesta fallida
      {
      "error_msg": "Failed to query the job."
         "error_code":"0162"
      }

Códigos de estado

Consulte Códigos de estado.

Códigos de error

Consulte Códigos de error.