Ververica Runtime (VVR) 8.0.3, introducido en esta versión, provoca pérdida de datos ocasionalmente en escenarios específicos, lo que afecta la precisión de los datos. Alibaba Cloud ha anunciado el fin del soporte (EOS) para VVR 8.0.3. Actualice a VVR 8.0.5 o posterior lo antes posible. Para obtener instrucciones de actualización, consulte Upgrade the engine version of deployments.
Esta versión de Realtime Compute for Apache Flink incluye actualizaciones del motor, funciones de plataforma, mejoras en conectores, optimizaciones de rendimiento y correcciones de bugs.
Despliegue: La actualización se implementa mediante una estrategia de lanzamiento canary durante un periodo de dos semanas. Una vez que la actualización llegue a su región y cuenta, la nueva versión del motor estará disponible para sus despliegues. Para más detalles, consulte Upgrade the engine version of deployments.
Actualizaciones del motor
Se publicó VVR 8.0.3, basado en Apache Flink 1.17.1. Esta versión mejora la interoperabilidad entre Realtime Compute for Apache Flink y otros servicios de Alibaba Cloud. También optimiza los conectores de MaxCompute, StarRocks, ApsaraDB for Redis, Simple Log Service y ApsaraMQ for RocketMQ para ofrecer un mejor rendimiento y mayor estabilidad. Además, mejora la usabilidad de la instrucción CREATE TABLE AS.
Las API de DataStream para los conectores mencionados anteriormente están planificadas para la próxima versión.
Funciones de plataforma
|
Función |
Novedades |
|
Ajuste automático optimizado |
La estrategia estable ya está disponible en Autopilot. El sistema ajusta la configuración de recursos solo cuando identifica una opción mejor para todo el tiempo de ejecución del despliegue. Esto evita modificaciones innecesarias causadas por picos repentinos de tráfico y ayuda a que los despliegues alcancen un estado de convergencia estable. Consulte Configure automatic tuning. |
|
Planes de ajuste programados |
Configure varios planes de ajuste programados para un solo despliegue. Cambie el plan activo sin cancelar el despliegue. Cada plan admite varias estrategias de ajuste programado. Consulte Configure automatic tuning. |
|
Linaje de datos para despliegues de Flink SQL |
Consulte el linaje de datos a nivel de campo para los despliegues de Flink SQL. Encuentre todos los despliegues que usan un campo específico en una tabla y rastree las relaciones a nivel de campo entre las tablas de origen y de resultados. Consulte View data lineage. |
|
Actualización dinámica de parámetros |
Actualice el parámetro Parallelism y parámetros de tiempo de ejecución específicos de un despliegue sin cancelarlo. Consulte Dynamically update the parameter configuration for dynamic scaling. |
|
Sugerencias de optimización de SQL |
Consulte sugerencias de optimización y riesgos potenciales directamente en los resultados de la verificación de sintaxis para despliegues de SQL. Consulte Develop an SQL draft. |
|
Búsqueda basada en etiquetas |
Asigne etiquetas a despliegues de SQL, JAR o Python y busque por clave o valor de etiqueta en la página Deployments. Consulte Create a deployment. |
|
Clasificación y filtrado mejorados de despliegues |
Ordene los despliegues por puntuación de salud o latencia, y filtre por el usuario que realizó la última modificación. Disponible en la página Deployments. |
|
Opciones de inicio de sesión ampliadas |
Inicie sesión en las consolas de administración y desarrollo mediante un rol de RAM, un miembro de directorio de recursos o un usuario de CloudSSO, además de las cuentas de Alibaba Cloud y los usuarios de Resource Access Management (RAM). Consulte Permission management, Authorize an account to perform operations in a namespace y Authorize access to Management Console. |
Mejoras en conectores y motor
|
Función |
Novedades |
|
MaxCompute: tipos de datos complejos y Tunnel exclusivo |
Lea y escriba tipos de datos JSON, ARRAY, MAP y STRUCT en MaxCompute. Asigne un Tunnel exclusivo de MaxCompute al conector para garantizar una conectividad dedicada. Consulte MaxCompute connector. |
|
ApsaraDB for Redis: política de caché ALL |
Establezca el parámetro |
|
ApsaraDB RDS for MySQL: compatibilidad con TDE |
Los catálogos de MySQL ahora son compatibles con instancias de ApsaraDB RDS for MySQL que tienen habilitado el cifrado transparente de datos (TDE). |
|
Catálogos de Data Lake Formation (DLF): endpoints de OSS-HDFS |
Configure el parámetro |
|
StarRocks: normalización de tipos en CREATE TABLE AS |
Habilite el modo de normalización de tipos para cambios de esquema cuando utilice el conector de StarRocks con |
|
Hologres: claves de partición DATE |
Utilice una columna DATE como clave de partición en tablas de resultados de Hologres. La tabla particionada se crea automáticamente. Consulte Hologres connector. |
|
ApsaraMQ for RocketMQ 5.x |
Lea y escriba datos en tablas de ApsaraMQ for RocketMQ 5.x. Consulte ApsaraMQ for RocketMQ connector. |
|
Mejora en el rendimiento de mini-batch y join |
Esta versión optimiza la función de mini-batch y el rendimiento de join. En escenarios de Change Data Capture (CDC), o después de operaciones de deduplicación y agregación, el rendimiento puede aumentar hasta en un 130 %. |
Problemas corregidos
Fallo de escritura en catálogo de MaxCompute en tablas particionadas: Se corrigió un error que ocurría al usar un catálogo de MaxCompute para escribir datos en una tabla particionada.
Rendimiento de join en tablas de dimensiones de Hologres: Se corrigió el bajo rendimiento al unir tablas de dimensiones de Hologres.