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.15 O Managed Service for Apache Flink suporta os seguintes novos recursos no Apache 1.15.2 **** | Recurso | Description | Referência ao Apache FLIP | | --- | --- | --- | | Coletor assíncrono | Uma estrutura AWS contribuída para criar destinos assíncronos que permite aos desenvolvedores criar AWS conectores personalizados com menos da metade do esforço anterior. Para obter mais informações, consulte [The Generic Asynchronous Base Sink](https://flink.apache.org/2022/05/06/async-sink-base.html). | [FLIP-171: Coletor assíncrono](https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink). | | Coletor do Kinesis Data Firehose | AWS contribuiu com um novo Amazon Kinesis Firehose Sink usando a estrutura Async. | [Coletor Amazon Kinesis Data Firehose](https://nightlies.apache.org/flink/flink-docs-release-1.15//docs/connectors/datastream/firehose/). | | Interromper com o Savepoint | Interromper com Savepoint garante uma operação de parada limpa e, mais importante, oferecendo suporte a semântica de exatamente uma vez para clientes que confiam nela. | [FLIP-34: Terminate/Suspend Job com o Savepoint](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=103090212). | | Desacoplamento do Scala | Agora, os usuários podem aproveitar a API Java de qualquer versão do Scala, incluindo o Scala 3. Os clientes precisarão incluir a biblioteca padrão Scala de sua seleção em seus aplicativos Scala. | [FLIP-28: Long-term objetivo de fazer uma mesa de flink Scala-free](https://cwiki.apache.org/confluence/display/FLINK/FLIP-28%3A+Long-term+goal+of+making+flink-table+Scala-free). | | Scala | Veja desacoplamento do Scala acima | [FLIP-28: Long-term objetivo de fazer uma mesa de flink Scala-free](https://cwiki.apache.org/confluence/display/FLINK/FLIP-28%3A+Long-term+goal+of+making+flink-table+Scala-free). | | Métricas unificadas de conectores | O Flink [definiu métricas padrão](https://nightlies.apache.org/flink/flink-docs-release-1.15//docs/ops/metrics/) para trabalhos, tarefas e operadores. O Managed Service for Apache Flink continuará a oferecer suporte às métricas de coletor e de fonte e, na versão 1.15, será introduzido numRestarts paralelamente às métricas fullRestarts de disponibilidade. | [FLIP-33: Padronize as métricas do conector eFLIP-179: exponha as métricas](https://cwiki.apache.org/confluence/display/FLINK/FLIP-33%3A+Standardize+Connector+Metrics) [padronizadas](https://cwiki.apache.org/confluence/display/FLINK/FLIP-179%3A+Expose+Standardized+Operator+Metrics) do operador. | | Verificação de tarefas concluídas | Esse recurso é ativado por padrão no Flink 1.15 e possibilita continuar executando pontos de verificação mesmo que partes do gráfico de trabalho tenham concluído o processamento de todos os dados, o que pode acontecer se ele contiver fontes limitadas (em lote). | [FLIP-147: Support Checkpoints após a conclusão das tarefas](https://cwiki.apache.org/confluence/display/FLINK/FLIP-147%3A+Support+Checkpoints+After+Tasks+Finished). | ## Alterações no Amazon Managed Service for Apache Flink com o Apache Flink 1.15 **Notebooks Studio** O Managed Service for Apache Flink Studio agora é compatível com o Apache Flink 1.15. O Managed Service for Apache Flink Studio utiliza blocos de anotações 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. Você pode aprender mais sobre o Managed Service for Apache Flink Studio e os conceitos básicos em. [Use um notebook Studio com Managed Service for Apache Flink](how-notebook.md) **Connector EFO** Ao atualizar para o Managed Service for Apache Flink versão 1.15, verifique se você está usando o conector EFO mais recente, ou seja, qualquer versão 1.15.3 ou mais recente. Para obter mais informações sobre o motivo, consulte [FLINK-29324](https://issues.apache.org/jira/browse/FLINK-29324 ). **Desacoplamento do Scala** A partir do Flink 1.15.2, você precisará agrupar a biblioteca padrão Scala de sua seleção em seus aplicativos Scala. **Coletor Kinesis Data Firehose ** Ao atualizar para o Managed Service for Apache Flink versão 1.15, certifique-se de usar o coletor [Amazon Kinesis Data Firehose](https://nightlies.apache.org/flink/flink-docs-release-1.15//docs/connectors/datastream/firehose/) mais recente. **Conetores Kafka** Ao atualizar para o Amazon Managed Service for Apache Flink para o Apache Flink versão 1.15, verifique se você está usando as APIs mais recentes do conetor Kafka. O Apache Flink foi descontinuado [FlinkKafkaConsumer](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-consumer)e [FlinkKafkaProducer](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-producer)essas APIs para o coletor Kafka não podem se comprometer com o Kafka para o Flink 1.15. Verifique se você está usando [KafkaSource[KafkaSink](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-sink)](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-source)e. ## Componentes **** | Componente | Versão | | --- | --- | | Java | 11 (recomendado) | | Scala | 2.12 | | Managed Service for Apache Flink Runtime (aws-kinesisanalytics-runtime) | 1.2.0 | | [AWS Conector Kinesis (conector flink-kinesis)](https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kinesis/1.15.4) | 1.15.4 | | [Apache Beam (somente aplicativos Beam)](https://aws.amazon.com/developer/language/python/) | 2.33.0, com Jackson versão 2.12.2 | ## Problemas conhecidos **O Kafka Commit no ponto de verificação falha repetidamente após a reinicialização do agente** Há um problema conhecido do Apache Flink de código aberto com o conector do Apache Kafka no Flink versão 1.15 causado por um bug crítico do Kafka Client de código aberto no Kafka Client 2.8.1. Para obter mais informações, consulte [Kafka Commit on checkpoint falha repetidamente após a reinicialização do broker](https://issues.apache.org/jira/browse/FLINK-28060) e KafkaConsumer não [consegue recuperar a conexão com o coordenador do grupo após a exceção](https://issues.apache.org/jira/browse/KAFKA-13840) de confirmação. OffsetAsync Para evitar esse problema, recomendamos usar o Apache Flink 1.18 ou posterior no Amazon Managed Service for Apache Flink.