O Ververica Runtime (VVR) 8.0.3, introduzido nesta versão, pode causar perda de dados em cenários específicos e afetar a precisão das informações. A Alibaba Cloud anunciou o fim do suporte (EOS) para o VVR 8.0.3. Atualize para o VVR 8.0.5 ou superior o mais rápido possível. Para obter instruções de atualização, consulte Upgrade the engine version of deployments.
Esta versão do Realtime Compute for Apache Flink inclui atualizações de engine, recursos de plataforma, melhorias em conectores, otimizações de desempenho e correções de bugs.
Implantação: A atualização é implantada por meio de uma estratégia de canary release ao longo de duas semanas. Quando a atualização chegar à sua região e conta, a nova versão da engine estará disponível para suas implantações. Para mais detalhes, consulte Upgrade the engine version of deployments.
Atualizações da engine
O VVR 8.0.3 foi lançado com base no Apache Flink 1.17.1. Esta versão melhora a interoperabilidade entre o Realtime Compute for Apache Flink e outros services da Alibaba Cloud. Além disso, otimiza os conectores MaxCompute, StarRocks, ApsaraDB for Redis, Simple Log Service e ApsaraMQ for RocketMQ para oferecer maior desempenho e estabilidade, e aprimora a usabilidade da instrução CREATE TABLE AS.
As APIs DataStream para os conectores listados acima estão planejadas para a próxima versão.
Recursos da plataforma
|
Recurso |
Novidades |
|
Ajuste automático otimizado |
A estratégia estável agora está disponível no Autopilot. O sistema ajusta a configuração de recursos apenas quando identifica uma opção melhor para todo o tempo de execução da implantação. Isso evita modificações desnecessárias causadas por picos repentinos de tráfego e ajuda as implantações a atingirem um estado de convergência estável. Consulte Configure automatic tuning. |
|
Planos de ajuste agendados |
Configure vários planos de ajuste agendados para uma única implantação. Alterne o plano ativo sem cancelar a implantação. Cada plano oferece suporte a várias estratégias de ajuste agendado. Consulte Configure automatic tuning. |
|
Linhagem de dados para implantações Flink SQL |
Visualize a linhagem de dados no nível de campo para implantações Flink SQL. Encontre todas as implantações que utilizam um campo específico em uma tabela e rastreie relacionamentos no nível de campo entre tabelas de source e de resultado. Consulte View data lineage. |
|
Atualização dinâmica de parâmetros |
Atualize o parâmetro Parallelism e parâmetros de runtime específicos de uma implantação sem precisar cancelá-la. Consulte Dynamically update the parameter configuration for dynamic scaling. |
|
Sugestões de otimização de SQL |
Visualize sugestões de otimização e riscos potenciais diretamente nos resultados da verificação de sintaxe para implantações SQL. Consulte Develop an SQL draft. |
|
Busca baseada em rótulos |
Atribua rótulos a implantações SQL, JAR ou Python e pesquise por chave ou valor de rótulo na página Deployments. Consulte Create a deployment. |
|
Classificação e filtragem avançadas de implantações |
Ordene implantações por pontuação de integridade ou latência e filtre pelo usuário responsável pela última modificação. Disponível na página Deployments. |
|
Opções de logon expandidas |
Faça logon nos consoles de gerenciamento e desenvolvimento usando uma função RAM, membro de diretório de recursos ou usuário CloudSSO, além de contas Alibaba Cloud e usuários do Resource Access Management (RAM). Consulte Permission management, Authorize an account to perform operations in a namespace e Authorize access to Management Console. |
Melhorias em conectores e na engine
|
Recurso |
Novidades |
|
MaxCompute: tipos de dados complexos e Tunnel exclusivo |
Leia e escreva tipos de dados JSON, ARRAY, MAP e STRUCT no MaxCompute. Atribua um MaxCompute Tunnel exclusivo ao conector para garantir conectividade dedicada. Consulte MaxCompute connector. |
|
ApsaraDB for Redis: política de cache ALL |
Defina o parâmetro |
|
ApsaraDB RDS for MySQL: suporte a TDE |
Os catálogos MySQL agora oferecem suporte a instâncias do ApsaraDB RDS for MySQL com criptografia transparente de dados (TDE) ativada. |
|
Catálogos do Data Lake Formation (DLF): endpoints OSS-HDFS |
Defina o parâmetro |
|
StarRocks: normalização de tipos em CREATE TABLE AS |
Ative o modo de normalização de tipos para alterações de schema ao usar o conector StarRocks com |
|
Hologres: chaves de partição DATE |
Utilize uma coluna DATE como chave de partição em tabelas de resultado do Hologres. A tabela particionada é criada automaticamente. Consulte Hologres connector. |
|
ApsaraMQ for RocketMQ 5.x |
Leia e escreva dados em tabelas do ApsaraMQ for RocketMQ 5.x. Consulte ApsaraMQ for RocketMQ connector. |
|
Desempenho aprimorado de mini-batch e join |
Esta versão otimiza o recurso de mini-batch e o desempenho de joins. Em cenários de Change Data Capture (CDC), ou após operações de deduplicação e agregação, o throughput pode aumentar em até 130%. |
Problemas corrigidos
Falha de escrita em tabelas particionadas via catálogo MaxCompute: Correção de um erro que ocorria ao usar um catálogo MaxCompute para gravar dados em uma tabela particionada.
Desempenho de join em tabelas de dimensão Hologres: Correção do baixo desempenho ao realizar joins com tabelas de dimensão do Hologres.