ParallelismConfigurationUpdate - Amazon Managed Service for Apache Flink (anteriormente Amazon Kinesis Data Analytics for Apache Flink)

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

ParallelismConfigurationUpdate

Descreve atualizações de parâmetros de como uma aplicação executa várias tarefas simultaneamente.

Conteúdo

AutoScalingEnabledUpdate

Descreve as atualizações se o serviço Managed Service for Apache Flink pode aumentar o paralelismo de uma aplicação do Managed Service for Apache Flink em resposta ao aumento do throughput.

Tipo: booliano

Obrigatório: não

ConfigurationTypeUpdate

Descreve as atualizações se a aplicação usa o paralelismo padrão para o serviço Managed Service for Apache Flink ou se um paralelismo personalizado é usado. Você deve definir essa propriedade como CUSTOM para alterar as propriedades AutoScalingEnabled, Parallelism ou ParallelismPerKPU de seu aplicativo.

Tipo: strings

Valores Válidos: DEFAULT | CUSTOM

Obrigatório: não

ParallelismPerKPUUpdate

Descreve o número de tarefas em paralelo que uma aplicação pode executar por unidade de processamento do Kinesis (KPU) usada pela aplicação.

Tipo: inteiro

Intervalo válido: valor mínimo de 1.

Obrigatório: não

ParallelismUpdate

Descreve as atualizações do número inicial de tarefas em paralelo que uma aplicação pode executar. Se AutoScalingEnabled estiver definido como True, o Managed Service for Apache Flink poderá aumentar o valor de CurrentParallelism em resposta à carga da aplicação. O serviço pode aumentar CurrentParallelism até o paralelismo máximo, que é ParalellismPerKPU vezes o máximo de KPUs da aplicação. O máximo de KPUs para uma aplicação é 32 por padrão e pode ser aumentado solicitando um aumento de limite. Se a carga da aplicação for reduzida, o serviço reduzirá CurrentParallelism até a configuração de Parallelism.

Tipo: inteiro

Intervalo válido: valor mínimo de 1.

Obrigatório: não

Consulte também

Para obter mais informações sobre como usar essa API em um dos AWS SDKs específicos da linguagem, consulte o seguinte: