Apache Flink 1.12.1 es un marco y un motor de procesamiento distribuido para cálculos con estado sobre flujos de datos ilimitados y acotados.
[ FLINK-18897 ]: agregar documentación para el formato maxwell-json
[ FLINK-20352 ] - Página de documentación de la interfaz de línea de comandos de retrabajo
[ FLINK-20353 ] - Página de documentación de registro de reelaboración
[ FLINK-20354 ] - Volver a trabajar la página de documentación de implementación independiente
[ FLINK-20355 ] - Página de documentación de implementación de Rework K8s
[ FLINK-20356 ] - Página de documentación de implementación de Rework Mesos
[ FLINK-20422 ] - Eliminar archivos de .html en la documentación de flink
[ FLINK-20485 ]: las vistas de mapa se deserializan varias veces
[ FLINK-20601 ]: reelaboración de la documentación de la CLI de PyFlink
[ FLINK-19369 ] - BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob se bloquea
[ FLINK-19435 ]: punto muerto al cargar diferentes clases de controladores al mismo tiempo con Class.forName
[ FLINK-19725 ] - El registrador no se puede inicializar debido al tiempo de espera: se lanza loggerInitializationException
[ FLINK-19880 ] - Corregir ignorar-analizar-errores que no funcionan para el formato JSON heredado
[ FLINK-20213 ]: la confirmación de la partición se retrasa cuando los registros siguen llegando
[ FLINK-20221 ] - DelimitedInputFormat no restaura correctamente las divisiones de archivos comprimidos que conducen a la pérdida de datos
[ FLINK-20273 ] - Corregir el error del documento del particionador del fregadero del conector Kafka de la API de la tabla
[ FLINK-20372 ] - Actualice la página del conector SQL de Kafka para mencionar las propiedades. * Opciones
[ FLINK-20389 ] - Fallo UnalignedCheckpointITCase causado por NullPointerException
[ FLINK-20404 ] - El quórum de ZooKeeper no se inicia debido a que falta la biblioteca log4j
[ FLINK-20419 ]: la inserción falla debido a que no se pudo generar el plan de ejecución
[ FLINK-20428 ] - ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization falló con "No se espera ningún resultado ya que no había ningún líder elegido antes de detener el servidor, todavía"
[ FLINK-20429 ] - KafkaTableITCase.testKafkaTemporalJoinChangelog falló con resultados inesperados
[ FLINK-20433 ] - UnalignedCheckpointTestBase.execute falló con "TestTimedOutException: la prueba agotó el tiempo de espera después de 300 segundos"
[ FLINK-20464 ]: algunos ejemplos de tablas no se han creado correctamente
[ FLINK-20467 ] - Corregir el ejemplo en Python DataStream Doc
[ FLINK-20470 ] - MissingNode no se puede convertir en ObjectNode al deserializar JSON
[ FLINK-20476 ] - Falló la prueba de extremo a extremo del nuevo receptor de archivos
[ FLINK-20486 ]: la unión temporal de Hive debe permitir un intervalo de monitorización inferior a 1 hora
[ FLINK-20492 ]: SourceOperatorStreamTask debería implementar cancelTask () y finishTask ()
[ FLINK-20493 ] - SQLClientSchemaRegistryITCase falló con "No se pudo construir la imagen flink-dist"
[ FLINK-20521 ]: el sistema RPC está absorbiendo los valores de resultado nulos
[ FLINK-20525 ] - StreamArrowPythonGroupWindowAggregateFunctionOperator no maneja rowtime y proctime correctamente
[ FLINK-20543 ] - Se corrigió un error tipográfico en los documentos de upsert kafka
[ FLINK-20554 ]: el tamaño de datos con puntos de control del último punto de control completado se muestra incorrectamente en la página de descripción general de la interfaz de usuario
[ FLINK-20582 ] - Corregir errores tipográficos en los documentos "CREATE Statements"
[ FLINK-20607 ]: un ejemplo incorrecto en la página udfs.
[ FLINK-20615 ]: tiempo de espera de prueba de extremo a extremo de programación permanente y recuperación local con "IOException: Stream Closed"
[ FLINK-20626 ]: si cancela un trabajo cuando falla, el trabajo se bloqueará en el estado CANCELANDO
[ FLINK-20630 ] - [Kinesis] [DynamoDB] El consumidor de transmisiones de DynamoDB no consume de la última
[ FLINK-20646 ] - ReduceTransformation no funciona con RocksDBStateBackend
[ FLINK-20648 ]: no se puede restaurar el trabajo desde el punto de rescate cuando se utilizan servicios de alta disponibilidad basados en Kubernetes
[ FLINK-20664 ] - Cuenta de servicio de configuración de soporte para el pod TaskManager
[ FLINK-20665 ] - FileNotFoundException al restaurar desde el último punto de control
[ FLINK-20666 ] - Se corrigió que la fila deserializada perdiera la información field_name en PyFlink
[ FLINK-20669 ] - Agrega el archivo de LICENCIA jzlib en el módulo flink-python
[ FLINK-20703 ]: tiempo de espera de la prueba HiveSinkCompactionITCase
[ FLINK-20704 ]: algunos tipos de datos rel no implementan el resumen correctamente
[ FLINK-20756 ]: PythonCalcSplitConditionRule no funciona como se esperaba
[ FLINK-20764 ] - BatchGroupedReduceOperator no emite resultados para entradas singleton
[ FLINK-20781 ] - Fallo UnalignedCheckpointITCase causado por NullPointerException
[ FLINK-20784 ] - .staging_xxx no existe, cuando se inserta en colmena
[ FLINK-20793 ] - Se corrigió la prueba de nombres debido a la refactorización del estilo del código
[ FLINK-20803 ]: la versión no coincide entre el complemento spotless -maven-plugin y el complemento google-java-format
[ FLINK-20841 ] - Soluciona el error de compilación debido a archivos generados duplicados
Mejora
[ FLINK-19013 ] - Registro de inicio / fin de la restauración del estado
[ FLINK-19259 ] - Use ganchos de liberación del cargador de clases con el productor de Kinesis para evitar fugas de metaespacio
[ FLINK-19832 ] - Mejora el manejo de la ranura física que falla inmediatamente en SlotSharingExecutionSlotAllocator
[ FLINK-20055 ] - Clave de API de Datadog expuesta en los registros de Flink JobManager
[ FLINK-20168 ] - Traducir la página 'Flink Architecture' al chino
[ FLINK-20209 ] - Agregar configuración de punto de control faltante a la interfaz de usuario de Flink
[ FLINK-20298 ] - Reemplazar el uso de la documentación de flink
[ FLINK-20468 ]: habilite el control de liderazgo en MiniCluster para probar la conmutación por error de JM
[ FLINK-20510 ]: habilita el intervalo de monitorización log4j2 de forma predeterminada
[ FLINK-20519 ]: ampliar el aviso de HBase con dependencias empaquetadas de forma transitiva
[ FLINK-20570 ] - El estilo de sugerencia `NOTE` es diferente de los demás en la página process_function.
[ FLINK-20588 ] - Agregue docker-compose como apéndice a la documentación de Mesos
[ FLINK-20629 ] - [Kinesis] [EFO] Migrar de DescribeStream a DescribeStreamSummary
[ FLINK-20647 ] - Use yield para generar datos de salida en ProcessFunction para Python DataStream
[ FLINK-20650 ] - Marque “native-k8s” como obsoleto en docker-entrypoint.sh
[ FLINK-20651 ]: use Spotless / google-java-format para formatear o hacer cumplir el código
[ FLINK-20682 ] - Agregar opciones de configuración relacionadas con hadoop
[ FLINK-20697 ] - Corrija el tipo de "lookup.cache.ttl" en jdbc.md/jdbc.zh.md
[ FLINK-20790 ] - Las clases generadas no deben colocarse en el directorio src /
[ FLINK-20792 ] - Permitir la invocación taquigráfica de impecable
[ FLINK-20805 ] - Clases de tiempo de ejecución de Blink parcialmente ignoradas por spotless
[ FLINK-20822 ] - No compruebe si una función es genérica en el catálogo de colmena
[ FLINK-20866 ] - Agregue cómo enumerar trabajos en la documentación de implementación de Yarn cuando HA habilitado
Tarea
[ FLINK-20300 ] - Crear notas de la versión de Flink 1.12
[ 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
