GetJobRun - E-MapReduce: Central de Documentação do Alibaba Cloud

Obtém os detalhes de uma execução de job Spark ao chamar GetJobRun.

Experimente agora

Experimente esta API no OpenAPI Explorer, sem necessidade de assinatura manual. Chamadas bem-sucedidas geram automaticamente código SDK correspondente aos seus parâmetros. Faça o download com segurança de credenciais integrada para uso local.

Testar

Autorização RAM

A tabela abaixo descreve a autorização necessária para chamar esta API. Você pode defini-la em uma política do Resource Access Management (RAM). As colunas da tabela estão detalhadas abaixo:

Ação: As ações que podem ser usadas no elemento Action das instruções de política de permissão do RAM para conceder permissões para executar a operação.
API: A API que você pode chamar para executar a ação.
Nível de acesso: O nível de acesso predefinido concedido para cada API. Valores válidos: create, list, get, update e delete.
Tipo de recurso: O tipo de recurso que suporta autorização para executar a ação. Indica se a ação suporta permissão em nível de recurso. O recurso especificado deve ser compatível com a ação. Caso contrário, a política será ineficaz.
- Para APIs com permissões em nível de recurso, os tipos de recursos obrigatórios são marcados com um asterisco (*). Especifique o Nome de Recurso Alibaba Cloud (ARN) correspondente no elemento Resource da política.
- Para APIs sem permissões em nível de recurso, é exibido como Todos os Recursos. Use um asterisco (*) no elemento Resource da política.
Chave de condição: As chaves de condição definidas pelo serviço. A chave permite controle granular, aplicando-se somente a ações ou a ações associadas a recursos específicos. Além das chaves de condição específicas do serviço, o Alibaba Cloud fornece um conjunto de chaves de condição comuns aplicáveis a todos os serviços compatíveis com RAM.
Ação dependente: As ações dependentes necessárias para executar a ação. Para concluir a ação, o usuário RAM ou a função RAM deve ter permissões para executar todas as ações dependentes.

Ação

Nível de acesso

Tipo de recurso

Chave de condição

Ação dependente

emr-serverless-spark:GetJobRun

get

*Todos os recursos.

*

Nenhuma

Sintaxe da solicitação

GET /api/v1/workspaces/{workspaceId}/jobRuns/{jobRunId} HTTP/1.1

Parâmetros de caminho

Parâmetro	Tipo	Obrigatório	Descrição	Exemplo
workspaceId	string	Sim	O ID do workspace.	w-d2d82aa09151****
jobRunId	string	Sim	O ID da execução do job.	jr-93d98d2f7061****

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Descrição	Exemplo
regionId	string	Não	O ID da região.	cn-hangzhou

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object	Os dados da resposta.
jobRun	object	Os detalhes da execução do job.
codeType	string	O tipo de código do job. Valores válidos: SQL JAR PYTHON	SQL
configurationOverrides	object	A configuração do job Spark.
configurations	array	A lista de configurações.
	Configuration	As informações de configuração.
displayReleaseVersion	string	A versão exibida no console.	esr-4.0.0 (Spark 3.5.2, Scala 2.12)
endTime	integer	A hora de término do job. O valor é um timestamp Unix em milissegundos.	1684122914000
environmentId	string	O ID do ambiente.	env-cpv569tlhtgndjl8****
executionTimeoutSeconds	integer	O período de tempo limite de execução.	3600
fusion	boolean	Especifica se a aceleração do mecanismo Fusion está ativada.	false
jobDriver	JobDriver	As informações do Spark Driver.
jobRunId	string	O ID da execução do job.	jr-93d98d2f7061****
log	RunLog	O caminho do log de execução.
name	string	O nome do job.	jobName
notebookAccessUrl	string	A URL de download do arquivo NOTEBOOK. Este parâmetro é retornado apenas se o tipo de job for NOTEBOOK.	http://workflow-ide-cn-hangzhou.oss-cn-hangzhou.aliyuncs.com/spark-notebook-output/w-xxxxxxxxx/xxxxxxx
priority	string	A prioridade do job.	5
releaseVersion	string	A versão do mecanismo Spark DPI usada para executar o nó.	esr-3.3.1
resourceOwnerId	string	O UID do usuário que criou o job.	150978934701****
resourceQueueId	string	O nome da fila usada para executar o job.	root_queue
state	string	O status do job.	Running
stateChangeReason	object	O motivo da alteração de status.
code	string	O código de erro.	ERR-100000
message	string	A mensagem de erro.	connection refused
submitTime	integer	A hora de envio do job. O valor é um timestamp Unix em milissegundos.	1684119314000
tags	array	A lista de tags.
	Tag	A tag.
tokenDetails	array<object>	Os detalhes do consumo de tokens.
	object	Os detalhes do consumo de tokens.
enableThinking	string	Especifica se o modo de raciocínio está ativado.	true
inputModality	string	A modalidade de entrada.	-
modelName	string	O nome do modelo.	qwen-plus
tokenRange	string	O intervalo de tokens de entrada.	0
tokenSource	string	A origem do token. Valores válidos: input e output.	input
tokenUsed	integer	O número de tokens consumidos.	10000
totalTokens	integer	O número total de tokens consumidos.	10000
webUI	string	A interface web do job.	http://spark-ui
workspaceId	string	O ID do workspace.	w-d2d82aa09155****
requestId	string	O ID da solicitação.	DD6B1B2A-5837-5237-ABE4-FF0C8944****

Exemplos

Resposta de sucesso

JSON formato

{
  "jobRun": {
    "codeType": "SQL",
    "configurationOverrides": {
      "configurations": [
        {
          "configFileName": "common.conf",
          "configItemKey": "hive.metastore.type",
          "configItemValue": "USER_RDS"
        }
      ]
    },
    "displayReleaseVersion": "esr-4.0.0 (Spark 3.5.2, Scala 2.12)",
    "endTime": 1684122914000,
    "environmentId": "env-cpv569tlhtgndjl8****",
    "executionTimeoutSeconds": 3600,
    "fusion": false,
    "jobDriver": {
      "sparkSubmit": {
        "entryPoint": "oss://bucket/path/to/entrypoint.jar",
        "entryPointArguments": [
          "arg1"
        ],
        "sparkSubmitParameters": "--conf spark.app.name=test"
      }
    },
    "jobRunId": "jr-93d98d2f7061****",
    "log": {
      "driverStdOut": "oss://bucket/path/to/stdout",
      "driverStdError": "oss://bucket/path/to/stderr",
      "driverSyslog": "oss://bucket/path/to/syslog",
      "driverStartup": "oss://bucket/path/to/startup"
    },
    "name": "jobName",
    "notebookAccessUrl": "http://workflow-ide-cn-hangzhou.oss-cn-hangzhou.aliyuncs.com/spark-notebook-output/w-xxxxxxxxx/xxxxxxx",
    "priority": "5",
    "releaseVersion": "esr-3.3.1",
    "resourceOwnerId": "150978934701****",
    "resourceQueueId": "root_queue",
    "state": "Running",
    "stateChangeReason": {
      "code": "ERR-100000",
      "message": "connection refused"
    },
    "submitTime": 1684119314000,
    "tags": [
      {
        "key": "workflowId",
        "value": "wf-123test"
      }
    ],
    "tokenDetails": [
      {
        "enableThinking": "true",
        "inputModality": "-",
        "modelName": "qwen-plus",
        "tokenRange": "0

Códigos de erro

Consulte Códigos de Erro para uma lista completa.

Notas de versão

Consulte Notas de Versão para uma lista completa.