SubmitSparkApp - AnalyticDB: Central de Documentação do Alibaba Cloud

Submete uma aplicação Spark.

Descrição da operação

Endpoint público regional: adb.<region-id>.aliyuncs.com. Exemplo: adb.cn-hangzhou.aliyuncs.com.
Endpoint da Virtual Private Cloud (VPC) regional: adb-vpc.<region-id>.aliyuncs.com. Exemplo: adb-vpc.cn-hangzhou.aliyuncs.com.

Nota

Se o código de status HTTP 409 for retornado ao chamar esta operação na região China (Qingdao), China (Shenzhen), China (Guangzhou) ou China (Hong Kong), entre em contato com o suporte técnico.

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

adb:SubmitSparkApp

create

*SparkApplication

acs:adb:{#regionId}:{#accountId}:dbcluster/{#DBClusterId}/resourcegroup/{#ResourceGroup}

Nenhuma

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Descrição	Exemplo
AppName	string	Não	O nome da aplicação. O valor pode ter até 64 caracteres.	TestApp
AppType	string	Não	O tipo da aplicação. Valores válidos: SQL STREAMING BATCH (padrão)	SQL
Data	string	Sim	Os dados do modelo de aplicação. Nota Para obter informações sobre a configuração do modelo de aplicação, consulte o Guia de configuração de aplicação Spark.	conf spark.driver.resourceSpec=small; conf spark.executor.instances=1; conf spark.executor.resourceSpec=small; conf spark.app.name=TestApp;
AgentSource	string	Não	O tipo do cliente. O valor pode ter até 64 caracteres.	CONSOLE
AgentVersion	string	Não	A versão do cliente. O valor pode ter até 64 caracteres.	1.091
DBClusterId	string	Sim	O ID do cluster da Enterprise Edition, Basic Edition ou Data Lakehouse Edition. Nota Você pode chamar a operação DescribeDBClusters para consultar os IDs de todos os clusters do AnalyticDB for MySQL em uma região.	amv-bp11q28kvl688****
ResourceGroupName	string	Sim	O nome do grupo de recursos do job. Nota Você pode chamar a operação DescribeDBResourceGroup para consultar o nome de um grupo de recursos em um cluster.	adb
TemplateFileId	integer	Não	O ID do modelo de aplicação. Nota Você pode chamar a operação GetSparkTemplateFullTree para consultar o ID do modelo de aplicação.	15

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object	Os parâmetros de resposta.
RequestId	string	O ID da solicitação.	1AD222E9-E606-4A42-BF6D-8A4442913CEF
Data	object	Os dados retornados.
AppId	string	O ID da aplicação.	s202204132018hzprec1ac61a000****
AppName	string	O nome da aplicação.	TestApp
Message	string	A mensagem de alerta retornada para a operação, como falha na execução da tarefa ou recursos insuficientes. Se nenhum alerta ocorrer, null será retornado.	Insufficient resources.
State	string	O estado de execução da aplicação. Valores válidos: SUBMITTED STARTING RUNNING FAILING FAILED KILLING KILLED SUCCEEDING COMPLETED FATAL UNKNOWN	SUBMITTED

Exemplos

Resposta de sucesso

JSON formato

{
  "RequestId": "1AD222E9-E606-4A42-BF6D-8A4442913CEF",
  "Data": {
    "AppId": "s202204132018hzprec1ac61a000****",
    "AppName": "TestApp",
    "Message": "Insufficient resources.",
    "State": "SUBMITTED"
  }
}

Códigos de erro

Código de status HTTP	Código de erro	Mensagem de erro	Descrição
400	Spark.App.ExceedQuotaLimitation	The requested resource exceeds the maximum limit: %s
400	Spark.App.InvalidAppTypeWhenSubmit	The specified AppType is INVALID or NULL. Please refer to the documentation to correct the parameters for %s.	The AppType type is illegal, please refer to using the document to specify the AppType suitable for your business.
400	Spark.App.InvalidResourceSpec	The requested resource type is not supported:\n %s
400	Spark.App.ParameterConflict	Conflicting parameters submitted:\n %s
400	Spark.App.ResourceNegativeError	The requested resource MUST be positive: %s
400	Spark.Config.InvalidAppFilePath	The main driver file MUST be a valid OSS path. Current is %s.
400	Spark.Config.invalidConnectors	The spark.adb.connectors configuration is invalid: %s
400	Spark.Config.InvalidDiskConfig	The requested disk mount parameter is invalid: %s
400	Spark.Config.InvalidHostAliasConfig	The requested host alias parameter %s is invalid. Example: 127.0.0.1 localhost local
400	Spark.Config.InvalidLogOssPath	The OSS address for log storage is illegal: %s
400	Spark.Config.InvalidRoleArnFormat	Configure RoleARN %s invalid format. It should match acs:ram::uid_number:role/role_name
400	Spark.Config.InvalidTimeZone	Unable to parse time zone configuration %s : %s
400	Spark.Config.MainAppFileNotExists	The main driver file is missing, [file] or [sqls] must be configured.
400	Spark.Config.OSSPathAccessError	The configured OSS address %s cannot be accessed.
400	Spark.Config.OSSPathNotExists	The OSS address %s requested does not exist or the permissions are insufficient.
400	Spark.Config.RoleArnVerifyFailed	RoleARN parameter verification failed. Error msg: %s when verify RoleArn %s
400	Spark.Config.SecurityGroupNotFound	The security group in the configuration does not exist or cannot be accessed. %s.	The configured resource group does not exist or cannot be accessed due to insufficient permissions. %s.
400	Spark.Config.VswitchNotFound	The vswitch in the configuration does not exist or cannot be accessed. %s.
400	Spark.InvalidParameter	Invalid parameter value: %s	Incorrect input parameter:%s.
400	Spark.InvalidState	The object of the operation is in an invalid state: %s	The operation object is invalid.
400	Spark.RoleArn.Invalid	%s is not found, or the RAM role has not been authorized.
400	Spark.SQL.BlankError	Input sql can not be blank string.
400	Spark.SQL.MultipleSQLError	Element in field [sqls] can not contain more than one sql statement: %s.
400	Spark.SQL.NotFoundExecutableSQLError	No executable statements are submitted. Please check the input SQL.
400	Spark.SQL.ParserError	Submit spark app failed when parser SQL %s. Error message: %s.
400	Spark.RoleARN.invalid	Current account fails to verify the permissions of the RAM system, please check the help information and configure the appropriate permissions for the current account.	Please make sure your current RAM user (ram_user_id %s) has been granted the system policy 'AliyunADBDeveloperAccess'. And then follow the section 'Perform authorization within an Alibaba Cloud account". This will automatically initialize the system role named 'aliyunadbsparkprocessingdatarole' in your cloud account. More details: https://www.alibabacloud.com/help/en/analyticdb/analyticdb-for-mysql/user-guide/create-the-aliyunadbsparkprocessingdatarole-role-for-a-ram-user-and-grant-permissions-to-the-role
500	Spark.ServerError	The Spark control component system encountered an error, please create a ticket to solve the problem or concat the supported engineer on duty. Error message: %s	An error occurred on the Spark control component system. Submit a ticket or contact technical support.
403	Spark.Forbidden	No permissions to access the resources: %s	Insufficient permissions to access the related resources. Information that you want to access: %s.
404	Spark.App.ContentNotFound	The requested content %s of the Spark application is not found.
404	Spark.App.NotFound	The Spark application %s is not found.
404	Spark.ObjectNotFound	The object is not found. More information: %s

Consulte Códigos de Erro para uma lista completa.

Notas de versão

Consulte Notas de Versão para uma lista completa.