Apache Flink 1.10.3 es un marco y un motor de procesamiento distribuido para cálculos con estado sobre flujos de datos ilimitados y acotados
Registro de cambios de Apache Flink v1.10.3
- [ FLINK-14087 ] - arroja java.lang.ArrayIndexOutOfBoundsException al emitir los datos usando RebalancePartitioner.
- [ FLINK-15170 ] - WebFrontendITCase.testCancelYarn falla en travis
- [ FLINK-15467 ]: debe esperar el final del hilo de origen durante la cancelación de la tarea
- [ FLINK-16246 ] - Excluya "SdkMBeanRegistrySupport" de los conectores AWS cargados dinámicamente
- [ FLINK-17341 ] - freeSlot en TaskExecutor.closeJobManagerConnection causa ConcurrentModificationException
- [ FLINK-17458 ] - TaskExecutorSubmissionTest # testFailingScheduleOrUpdateConsumers
- [ FLINK-17677 ] - El FLINK_LOG_PREFIX recomendado en los documentos no siempre está disponible
- [ FLINK-18081 ] - Corrija los enlaces rotos en el documento "Configuración y configuración de autenticación Kerberos"
- [ FLINK-18196 ] - Flink lanza "NullPointerException" cuando se ejecuta
- [ FLINK-18212 ] - Error al iniciar la combinación de búsqueda cuando se usa udf en la tabla de búsqueda
- [ FLINK-18832 ]: la subpartición BoundedBlockingSubpartition no funciona con StreamTask
- [ FLINK-18959 ] - Error al archivarExecutionGraph porque el trabajo no está terminado cuando se cierra el despachador
- [ FLINK-19022 ] - AkkaRpcActor no pudo iniciarse pero no hay información de excepción
- [ FLINK-19109 ] - El lector dividido come marcas de agua periódicas encadenadas
- [ FLINK-19135 ] - (Stream) ExecutionEnvironment.execute () no debería lanzar ExecutionException
- [ FLINK-19237 ] - LeaderChangeClusterComponentsTest.testReelectionOfJobMaster falló con "NoResourceAvailableException: no se pudo asignar el espacio requerido dentro del tiempo de espera de la solicitud de espacio"
- [ FLINK-19401 ] - Trabajo atascado en el ciclo de reinicio debido a recuperaciones excesivas de puntos de control que bloquean JobMaster
- [ FLINK-19557 ] - Problema al recuperar el líder después de volver a conectar la sesión del cuidador del zoológico
- [ FLINK-19675 ] - El plan de es incorrecto cuando Calc contiene la cláusula WHERE, el acceso a campos compuestos y Python UDF al mismo tiempo
- [ FLINK-19901 ]: no se pueden excluir las variables de métricas para el último informador de métricas.
- [ FLINK-20013 ] - La subpartición BoundedBlockingSubpartition puede perder el búfer de red si la tarea falla o se cancela
- [ FLINK-20018 ]: la opción pipeline.cached-files no puede escapar de ':' en la ruta
- [ FLINK-20033 ]: el trabajo falla al detener JobMaster
- [ FLINK-20065 ] - UnalignedCheckpointCompatibilityITCase.test falló con AskTimeoutException
- [ FLINK-20076 ] - DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles no prueba la funcionalidad deseada
- [ FLINK-20183 ]: se corrige que el PYTHONPATH predeterminado se sobrescriba en el lado del cliente
- [ FLINK-20218 ] - AttributeError: el módulo 'urllib' no tiene el atributo 'parse'
- [ FLINK-20875 ] - [CVE-2020-17518] Ataque transversal de directorio: escritura remota de archivos a través de la API REST
Mejoras
- [ FLINK-16753 ] - La excepción de AsyncCheckpointRunnable debe incluirse en CheckpointException
- [ FLINK-18287 ] - Corrija la documentación de la API de tabla de Python en páginas SQL
- [ FLINK-19055 ] - MemoryManagerSharedResourcesTest contiene tres pruebas que se ejecutan durante mucho tiempo
- [ FLINK-19105 ] - Error de código de muestra de API de tabla
- [ FLINK-19252 ] - Archivo Jaas creado en io.tmp.dirs - carpeta no creada si no existe
- [ FLINK-19339 ] - Apoye las uniones de Avro con tipos lógicos
- [ FLINK-19523 ] - Ocultar configuraciones sensibles de la línea de comandos
Tarea
- [ FLINK-20906 ] - Actualice el año de copyright a 2021 para archivos NOTICE
Gracias por visitar este sitio, espero que te haya gustado y vuelvas proximamente, compartela en las redes sociales, gracias
Fecha actualización el 2021-02-02. Fecha publicación el 2021-02-02. Categoría: Download Autor: Oscar olg Mapa del sitio Fuente: meterpreter