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á.
Amazon Managed Service for Apache Flink 1.20
O Managed Service for Apache Flink agora oferece suporte ao Apache Flink versão 1.20.5. Esta seção apresenta os principais novos recursos e mudanças introduzidos com o Managed Service para suporte ao Apache Flink do Apache Flink 1.20.5. Espera-se que o Apache Flink 1.20 seja a última versão 1.x e de suporte de longo prazo (LTS) do Flink. Para obter mais informações, consulte FLIP-458: Long-Term Suporte para a versão final da linha Apache Flink 1.x.
nota
Se você estiver usando uma versão anterior suportada do Apache Flink e quiser atualizar seus aplicativos existentes para o Apache Flink 1.20.5, você pode fazer isso usando as atualizações de versão do Apache Flink no local. Para obter mais informações, consulte Use atualizações de versão in-place para o Apache Flink. Com as atualizações de versão in-place, você mantém a rastreabilidade do aplicativo em relação a um único ARN nas versões do Apache Flink, incluindo snapshots, registros, métricas, tags, configurações do Flink e muito mais.
Recursos compatíveis
O Apache Flink 1.20.5 introduz melhorias nas APIs do SQL, nas APIs e no painel do DataStream Flink.
| Recursos compatíveis | Description | Referência da documentação do Apache Flink |
|---|---|---|
| Adicionar cláusula DISTRIBUTED BY | Muitos mecanismos SQL expõem os conceitos de Partitioning, Bucketing ou Clustering. O Flink 1.20 introduz o conceito de Bucketing no Flink. |
FLIP-376: Adicionar cláusula DISTRIBUTED BY |
| DataStream API: suporte ao processamento completo de partições | O Flink 1.20 introduz suporte integrado para agregações em fluxos sem chave por meio da API FullPartitionWindow. |
FLIP-380: Suporta processamento completo de partições em Non-keyed DataStream |
| Mostrar pontuação de distorção de dados no painel do Flink | O painel do Flink 1.20 agora mostra informações de distorção de dados. Cada operador na interface do gráfico de tarefas do Flink mostra uma pontuação adicional de distorção de dados. | FLIP-418: Mostrar pontuação de distorção de dados no Flink Dashboard |
Para ver a documentação de lançamento do Apache Flink 1.20.5, consulte a documentação do Apache Flink v1.20.5 no site do
Componentes
| Componente | Versão |
|---|---|
| Java | 11 (recomendado) |
| Python |
3,11 |
| Runtime do Kinesis Data Analytics Flink (aws-kinesisanalytics-runtime) | 1.2.0 |
| Conectores | Para obter informações sobre os conectores disponíveis, consulte Conectores do Apache Flink. |
| Apache Beam (somente aplicativos Beam) |
A partir da versão 2.70.0. Para obter mais informações, consulte Compatibilidade de versões do Flink |
Problemas conhecidos
Serviço gerenciado da Amazon para Apache Flink Studio
O Amazon Managed Service for Apache Flink Studio utiliza notebooks do Apache Zeppelin para fornecer uma experiência de desenvolvimento de interface única para desenvolvimento, depuração de código e execução de aplicativos de processamento de stream do Apache Flink. É necessário atualizar o Flink Interpreter do Zeppelin para permitir o suporte do Flink 1.20. Este trabalho está agendado com a comunidade Zeppelin. Atualizaremos essas notas quando o trabalho for concluído. É possível continuar usando o Flink 1.15 com o Amazon Managed Service for Apache Flink Studio. Para obter mais informações, consulte Criação de um notebook do Studio.
Correções de bugs retroportadas
O Amazon Managed Service for Apache Flink é responsável pelas correções da comunidade do Flink para problemas críticos. A seguir está uma lista de correções de bugs em que aplicamos backport:
| Link para o Apache Flink JIRA | Description |
|---|---|
| FLINK-35886 |
Essa correção soluciona um problema que causa a contabilização incorreta dos tempos limite de ociosidade da marca d'água quando ocorre uma subtarefa. backpressured/blocked |
