Download Apache Flink 1.12.1

download imagen relacionada

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

Download Apache Flink 1.12.1

Gracias por visitar este sitio, espero que te haya gustado y vuelvas proximamente, compartela en las redes sociales, gracias

Compartir en Facebook Compartir en twitter

Semrush sigue a tu competencia

Fecha actualización el 2021-01-21. Fecha publicación el 2021-01-21. Categoría: Download Autor: Oscar olg Mapa del sitio Fuente: meterpreter