Realtime Compute for Apache Flink:Versión 2025-10-13

Ingesta de datos

Origen Kafka: El formato Canal-JSON ahora analiza sintácticamente los campos nativos MySQL_TYPE, lo que mejora la fidelidad de tipos al consumir eventos de cambio de MySQL.

Conectores

• Conector Hologres: Ahora puede especificar el tipo de registro binario que desea leer para lograr un control más granular sobre la sincronización de datos.

• Conector StarRocks: Se actualizó para alinearse con la versión 1.2.11 de StarRocks Connector for Flink.

• Conector Lindorm: Las tablas de dimensiones ahora admiten uniones de uno a muchos.

• Conector MaxCompute: Ahora puede establecer una zona horaria personalizada para el procesamiento de datos entre distintas zonas horarias.

• Conector SLS: El parámetro processor le permite prefiltrar los datos de Simple Log Service (SLS) antes de consumirlos, lo que reduce los costos de procesamiento posteriores.

Capacidades de IA

• Búsqueda vectorial: La función VECTOR_SEARCH ejecuta búsquedas de similitud en tiempo real mediante Milvus. Consulte VECTOR_SEARCH.

• Función de IA: Hay más parámetros configurables disponibles para ofrecer un mayor control sobre el comportamiento de la función de IA.

SQL y gestión de datos

• Conversión JSON: Utilice la función JSON_QUERY para convertir directamente un arreglo dentro de una cadena JSON a ARRAY<STRING>. Consulte Funciones JSON.

• Catálogo StarRocks: Ya no es necesario pasar explícitamente una URL al utilizar el catálogo de StarRocks.

Optimizaciones de rendimiento

• Conector MySQL: Se optimizó el pushdown de predicados para tipos booleanos, lo que reduce la transferencia innecesaria de datos.

• Conector Hologres: Ahora se aplican pushdown de proyección y compresión de datos al consumir registros binarios, lo que disminuye la sobrecarga de red y de procesamiento.

• Conector MaxCompute: Se mejoró el rendimiento de escritura de tipos complejos, como arreglos, en tablas regulares.

Nuevas capacidades

Mejoras en la experiencia de la plataforma

Experiencia de compra

Se eliminó el límite de 1,000 unidades de cómputo (CU) para espacios de trabajo con suscripción. Esto aplica a ampliaciones, nuevas compras y conversiones de pay-as-you-go a suscripción, lo que habilita el escalado elástico para trabajos a gran escala.

Observability

• Visualización unificada de métricas de recolección de basura (GC): Las métricas de GC ahora son compatibles con ParallelGC y CMS, lo que permite un monitoreo unificado entre distintos tipos de GC.

• **Nueva métrica busyTimePerSecond**: Proporciona información precisa sobre la carga del trabajo para ayudarle a identificar cuellos de botella de rendimiento, asignar recursos de manera eficaz y garantizar la estabilidad del trabajo.

Modelo de permisos

Los permisos de carpetas ahora están unificados con los permisos de borradores de trabajos y consultas de datos. Puede crear carpetas sin encontrar errores de permisos.

Tabla materializada

Al editar una tabla materializada, ahora puede actualizar la versión de Ververica Runtime (VVR) directamente desde el editor. Este también admite la comparación de versiones y actualiza automáticamente el despliegue del trabajo.

Configuración de entrega de mensajes

Puede personalizar el alcance de entrega de los mensajes para lograr un control más granular y reducir los costos de notificación.