Esta página describe los cambios incluidos en la versión del 4 de agosto de 2021 de Realtime Compute for Apache Flink, que abarca Ververica Platform (VVP) y Ververica Runtime (VVR) 4.0.8.
Acciones obligatorias antes de actualizar
Lea esta sección antes de actualizar. Estos cambios requieren acciones específicas para evitar fallos en los trabajos o pérdida de datos.
Detener un trabajo ahora elimina todos sus puntos de control. Si necesita restaurar el estado del trabajo después de detenerlo, utilice uno de los siguientes métodos:
Suspender y reanudar: al suspender un trabajo se conserva su estado, lo que permite reanudarlo from el punto where se detuvo.
Restaurar from un savepoint: detenga el trabajo y luego restáurelo a partir de un savepoint creado previamente.
La migración de versión del motor es obligatoria para trabajos en Flink 1.11 o anteriores.
A partir de VVR 3.0.3, VVP admite la ejecución simultánea de trabajos SQL con distintas versiones del motor. El formato de la versión del motor también cambió a vvr-<VVR version>-flink-<Flink version>.
Realice la acción correspondiente según su versión actual del motor:
|
Versión actual del motor |
Acción obligatoria |
|
Flink 1.12 |
Detenga y reinicie el trabajo. VVP actualiza automáticamente la versión del motor a |
|
Flink 1.11 o Flink 1.10 |
Actualice manualmente la versión del motor a |
Nuevas funciones
Trabajos SQL
Configuración detallada de recursos: configure núcleos de CPU y tamaño de memoria para slots compartidos en trabajos SQL. Esto le permite ajustar los recursos por trabajo en lugar de aplicar una única configuración global al clúster. Consulte Configure a deployment.
Gestión de versiones: publicar un trabajo ahora genera una versión de desarrollo. Compare versiones lado a lado y revierta a cualquier versión histórica si una nueva publicación presenta problemas. Consulte Manage job versions.
Catálogo de Hologres: cree un catálogo de Hologres en la consola de desarrollo para acceder a tablas y leer metadatos de Hologres sin salir de Realtime Compute for Apache Flink. Consulte Manage Hologres catalogs.
Trabajos SQL multiversión: publique trabajos SQL con diferentes versiones del motor en el mismo espacio de trabajo. Versiones compatibles:
vvr-3.0.3-flink-1.12yvvr-4.0.8-flink-1.13.
Conectores
Conector MySQL CDC: admite lectura completa de datos en varios hilos paralelos, algoritmos sin bloqueo y carga reanudable.
Conector AnalyticDB for MySQL V3.0: ahora es compatible con la semántica
ON DUPLICATE KEY UPDATE.Conector ApsaraDB RDS for MySQL: actualice la versión del controlador Java Database Connectivity (JDBC) para admitir más conjuntos de caracteres.
Monitoreo y alertas
Frecuencia de alertas: configure la frecuencia de activación de las alertas para reducir el ruido en escenarios de alta frecuencia.
Alertas por webhook: envíe alertas directamente a un endpoint de webhook para integrarlas con sistemas externos de notificación.
Mejoras
Carga más rápida de paquetes JAR: se optimizó el método de carga, lo que reduce el tiempo necesario para cargar paquetes JAR.
Nombres de trabajos en los registros: los nombres de los trabajos ahora se incluyen en los registros descargados a Log Service, lo que facilita identificar qué trabajo generó una entrada de registro específica.
Correcciones de bugs
Se corrigió un problema en el que la métrica
currentEmitEventTimeLagmostrabaLog.MAXcuando algunas particiones de una tabla de Kafka no tenían datos.