Este tema describe las principales actualizaciones de funciones y correcciones de bugs en la versión de Realtime Compute for Apache Flink del 30 de noviembre de 2025.
Esta actualización se implementa de forma gradual. Consulte el anuncio más reciente en la consola de Realtime Compute for Apache Flink para confirmar si la actualización se completó en su cuenta. Para solicitar una actualización acelerada, envíe un ticket.
Descripción general
Esta versión introduce Ververica Runtime (VVR) 11.4.0. Los aspectos más destacados incluyen siete nuevas funciones de IA en Flink SQL, alineación con Flink Change Data Capture (CDC) 3.5, nuevos conectores de origen para PostgreSQL CDC y MongoDB, mejoras en conectores para Kafka, Hologres, JDBC, Apache Paimon y Redis, un nuevo catálogo de PostgreSQL, así como mejoras en la plataforma para la gestión de namespaces, control de acceso y visibilidad operativa.
|
Área |
Novedades |
|
Motor — IA |
Siete nuevas funciones de IA en Flink SQL para procesamiento de texto |
|
Motor — Ingesta de datos |
Alineación con Flink CDC 3.5; origen PostgreSQL CDC (Public Preview); origen MongoDB |
|
Motor — Conectores |
Mejoras en Kafka, Hologres, JDBC, Apache Paimon y Redis |
|
Catálogo |
Nuevo catálogo de PostgreSQL; mejoras en catálogos de StarRocks y MaxCompute |
|
Plataforma |
Clonación de namespaces, cambio de servicio de monitoreo, granularidad en control de acceso y archivado de registros basado en RAM |
|
Correcciones de bugs |
Conector Kafka, Prometheus Metric Reporter, MySQL CDC, facturación híbrida y namespace |
Motor
Funciones de IA
VVR 11.4.0 agrega siete funciones de IA a Flink SQL para el procesamiento de texto en pipelines de streaming.
|
Función |
Descripción |
Caso de uso |
|
Clasifica texto en categorías predefinidas y devuelve una puntuación de confianza |
Categorización de tickets, etiquetado de contenido |
|
|
Devuelve una puntuación cuantitativa de sentimiento con una etiqueta positiva, negativa o neutra |
Análisis de comentarios, monitoreo de opinión pública |
|
|
Extrae datos estructurados, como nombres y números telefónicos, desde texto no estructurado mediante un esquema JSON |
— |
|
|
Genera un resumen de textos largos con una longitud máxima configurable |
— |
|
|
Crea representaciones vectoriales de alta dimensión a partir de texto |
Cálculos de similitud, recuperación semántica |
|
|
Traduce texto entre más de 10 idiomas con detección automática del idioma de origen |
— |
|
|
Enmascara información sensible, como números telefónicos y números de identificación, dentro del texto |
Cumplimiento de privacidad, protección de PII |
Ingesta de datos
Alineación con Flink CDC 3.5 — Se alinea con Apache Flink CDC 3.5.
**PostgreSQL CDC — Public Preview** — Agrega PostgreSQL como conector de origen CDC.
**MongoDB** — Agrega MongoDB como conector de origen.
Conectores
Kafka
El formato Canal-JSON ahora admite el análisis sintáctico de eventos de índice de la base de datos de origen. También es posible obtener la clave y el valor originales como metadatos.
Admite Protocol Buffers v3 (proto3).
Hologres
Las uniones de búsqueda en tablas de dimensiones admiten pushdown de filtros.
Stream Copy admite el formato BinaryRow.
Permite configurar estrategias de conflicto de clave primaria para operaciones INSERT.
JDBC (PostgreSQL)
Agrega la opción
ignore deletepara ignorar eventos de eliminación provenientes de la tabla de origen.
Apache Paimon
Admite actualizaciones entre particiones.
Admite un prefijo de nombre de usuario para facilitar la localización de trabajos.
Redis
Se mejoró la compatibilidad con instancias de clúster y escrituras por lotes.
Catálogo
**Catálogo de PostgreSQL — Nuevo** — Introduce un catálogo de PostgreSQL para gestionar metadatos de PostgreSQL en Flink SQL.
**StarRocks catalog** — Permite tratar columnas de clave primaria anulables en StarRocks como no anulables.
**MaxCompute catalog** — Admite la asignación de una base de datos a un proyecto o esquema de MaxCompute.
Plataforma
Funciones principales
Copie namespaces entre espacios de trabajo para migración y pruebas de ejecución dual
La clonación de namespaces permite copiar un namespace a otros espacios de trabajo. Utilice esta función al migrar clústeres o ejecutar pruebas duales antes del corte definitivo.
Cambie el servicio de monitoreo de un espacio de trabajo directamente desde la consola
Ahora puede cambiar manualmente el servicio de monitoreo de su espacio de trabajo desde la consola.
Control de acceso más granular para permisos deshabilitados e integración con Git
Configure puntos de permiso
disabledpara el control de acceso.Establezca permisos granulares para la integración con Git de manera independiente a otras reglas de control de acceso.
Archive registros en Simple Log Service (SLS) mediante RAM en lugar de pares AccessKey
El archivado de registros ahora utiliza Resource Access Management (RAM) para la autenticación en lugar de pares AccessKey, lo que mejora la seguridad.
Experiencia de usuario
La página de O&M ahora muestra resultados de actualizaciones dinámicas y ajuste automático
La página de Operaciones y Mantenimiento (O&M) muestra el estado y los resultados de las actualizaciones dinámicas y el ajuste automático.
Etiquetas de facturación aplicadas automáticamente en espacios de trabajo con facturación híbrida
En un espacio de trabajo con facturación híbrida, los recursos se etiquetan automáticamente como subscription o pay-as-you-go para facilitar la división de la facturación.
Busque recursos por espacio de trabajo, ID de espacio de trabajo o namespace
La búsqueda de recursos ahora acepta el nombre del espacio de trabajo, el ID del espacio de trabajo o el namespace como criterios de búsqueda.
Correcciones importantes de bugs
Conector Kafka: Se solucionó un problema donde los trabajos se suspendían debido a acumulaciones de transacciones.
Prometheus Metric Reporter: Se corrigió un desbordamiento de búfer causado por conexiones de red sin cerrar.
MySQL CDC: Se resolvió un problema que impedía leer archivos de registro binario archivados desde OSS.
Facturación híbrida: Se corrigió un error por el cual cancelar el pedido durante la activación provocaba fallos en la reactivación.
Namespace: Se corrigió un bug que impedía iniciar sesión en Development Console; ahora se garantiza que no sea posible eliminar el último namespace.