卷起来了,Apache Flink 1.13.6 发布!

2024-09-06 17:08
文章标签 发布 apache flink 起来 1.13

本文主要是介绍卷起来了,Apache Flink 1.13.6 发布!,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

点击上方蓝色字体,选择“设为星标”

回复"面试"获取更多惊喜

3890c6451c5add0e251d7896a8f20ec9.png

Hi,我是王知无,一个大数据领域的原创作者。 

放心关注我,获取更多行业的一手消息。

Apache Flink 社区发布了 Flink 1.13 的另一个错误修复版本。

此版本包括99个错误和漏洞修复以及 Flink 1.13 的小改进,包括 Apache Log4j 的另一次升级(到 2.17.1)。您将在下面找到所有错误修复和改进的列表(不包括对构建基础架构和构建稳定性的改进)。有关所有更改的完整列表,请参阅JIRA列表。

我们强烈建议所有用户升级到 Flink 1.13.6。

新的Maven依赖

<dependency><groupId>org.apache.flink</groupId><artifactId>flink-java</artifactId><version>1.13.6</version>
</dependency>
<dependency><groupId>org.apache.flink</groupId><artifactId>flink-streaming-java_2.11</artifactId><version>1.13.6</version>
</dependency>
<dependency><groupId>org.apache.flink</groupId><artifactId>flink-clients_2.11</artifactId><version>1.13.6</version>
</dependency>

修复漏洞

  • [ FLINK-15987 ] - SELECT 1.0e0 / 0.0e0 抛出 NumberFormatException

  • [ FLINK-17914 ] - 如果存档列表失败,HistoryServer 会删除缓存的存档

  • [ FLINK-20195 ] - Jobs 端点返回重复的作业

  • [ FLINK-20370 ] - sink 主键与查询不同时结果错误

  • [ FLINK-21289 ] - 应用程序模式忽略 pipeline.classpaths 配置

  • [ FLINK-23919 ] - PullUpWindowTableFunctionIntoWindowAggregateRule 为 Window TVF 生成无效的 Calc

  • [ FLINK-24232 ] - 暂停作业的存档可防止中断后续存档尝试

  • [ FLINK-24255 ] - 测试环境/迷你集群不转发配置。

  • [ FLINK-24310 ] - 文档中 BufferingSink 示例中的错误

  • [ FLINK-24318 ] - 将数字转换为布尔值在“选择”字段和“位置”条件之间有不同的结果

  • [ FLINK-24334 ] - 配置 kubernetes.flink.log.dir 不起作用

  • [ FLINK-24366 ] - 当任务已被取消时,有关还原失败的不必要/误导性错误消息。

  • [ FLINK-24401 ] - Metaspace OOM 后 TM 无法退出

  • [ FLINK-24465 ] - 缓冲区超时的错误 javadoc 和文档

  • [ FLINK-24492 ] - numeric 和 (var)char 之间不正确的隐式类型转换

  • [ FLINK-24506 ] - 检查点目录无法通过传递给 StreamExecutionEnvironment 的 Flink 配置进行配置

  • [ FLINK-24509 ] - 由于使用了不正确的构造函数签名,FlinkKafkaProducer 示例未编译

  • [ FLINK-24540 ] - 修复 Files.list 导致的资源泄漏

  • [ FLINK-24543 ] - Zookeeper 连接问题导致 Flink 中的状态不一致

  • [ FLINK-24563 ] - 将 timstamp_ltz 与随机字符串进行比较会抛出 NullPointerException

  • [ FLINK-24597 ] - RocksdbStateBackend getKeysAndNamespaces 在使用 MapState 时会返回重复数据

  • [ FLINK-24621 ] - 由于 InflightDataRescalingDescriptor,JobManager 无法恢复 1.13.1 检查点

  • [ FLINK-24662 ] - PyFlink sphinx 检查失败,"节点类 'meta' 已注册,其访问者将被覆盖"

  • [ FLINK-24667 ] - 如果之前遇到异常,通道状态编写器将直接失败任务

  • [ FLINK-24676 ] - 如果用部分列解释插入语句,则架构不匹配

  • [ FLINK-24678 ] - 更正地图状态的度量名称包含延迟

  • [ FLINK-24708 ] - ConvertToNotInOrInRule 有一个导致错误结果的错误

  • [ FLINK-24728 ] - 批处理 SQL 文件接收器忘记关闭输出流

  • [ FLINK-24761 ] - 修复 PartitionPruner 代码生成编译失败

  • [ FLINK-24846 ] - AsyncWaitOperator 在 stop-with-savepoint 期间失败

  • [ FLINK-24860 ] - 修复 Python UDTF 中错误的位置映射

  • [ FLINK-24885 ] - ProcessElement 接口参数收集器:java.lang.NullPointerException

  • [ FLINK-24922 ] - 修复单词“parallism”中的拼写错误

  • [ FLINK-25022 ] - 通过 REST API 提交作业时,JM 上的 ThreadLocals 的 ClassLoader 泄漏

  • [ FLINK-25067 ] - 更正 RocksDB 后台线程的描述

  • [ FLINK-25084 ] - 字段名称必须是唯一的。找到重复项

  • [ FLINK-25091 ] - 官网文档FileSink orc压缩属性引用错误

  • [ FLINK-25096 ] - flink 1.13.2 中的异常 API(/jobs/:jobid/exceptions) 中的问题

  • [ FLINK-25199 ] - StreamEdges 在自联合中不是唯一的,它会阻止水印的传播

  • [ FLINK-25362 ] - Table Confluent/Avro 文档中的依赖关系不正确

  • [ FLINK-25468 ] - 如果本地状态存储和 RocksDB 工作目录不在同一个卷上,则本地恢复失败

  • [ FLINK-25486 ] - 当 zookeeper 领导者改变时,Perjob 无法从检查点恢复

  • [ FLINK-25494 ] - DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources 期间重复的元素序列化程序

  • [ FLINK-25513 ] - CoFlatMapFunction 需要两个 flat_map 才能产生一些东西

  • [ FLINK-25559 ] - SQL JOIN 导致数据丢失

  • [ FLINK-25683 ] - 如果表转换为 DataStream 则结果错误,然后在批处理模式下进行窗口处理

  • [ FLINK-25728 ] - StreamMultipleInputProcessor 中潜在的内存泄漏

  • [ FLINK-25732 ] - Dispatcher#requestMultipleJobDetails 返回不可序列化的集合

改进

  • [ FLINK-21407 ] - 明确哪些来源和 API 支持哪些格式

  • [ FLINK-20443 ] - ContinuousProcessingTimeTrigger 不会在窗口结束时触发

  • [ FLINK-21467 ] - 记录 Bounded{One/Multi}Input.endInput 的可能推荐用法,并强调它们可以被多次调用

  • [ FLINK-23842 ] - 为读者注册和拆分请求添加日志消息。

  • [ FLINK-24631 ] - 避免直接使用标签作为部署和服务的选择器

  • [ FLINK-24739 ] - 在文档中说明 Flink 的应用模式的要求

  • [ FLINK-24987 ] - 增强 ExternalizedCheckpointCleanup 枚举

  • [ FLINK-25160 ] - 使文档清晰:可容忍失败检查点计数连续失败

  • [ FLINK-25415 ] - 实现对 Cassandra 容器连接的重试

  • [ FLINK-25611 ] - 移除 CoordinatorExecutorThreadFactory 线程创建保护

  • [ FLINK-25818 ] - 添加解释当并行度高于分区数时 Kafka Source 如何处理空闲

技术债务

  • [ FLINK-24740 ] - 将 testcontainers 依赖更新到 v1.16.2

  • [ FLINK-24796 ] - 从 CI 编译工件中排除 javadocs / node[_modules] 目录

  • [ FLINK-25472 ] - 更新到 Log4j 2.17.1

  • [ FLINK-25375 ] - 将 Log4j 更新到 2.17.0

  • [ FLINK-25576 ] - 将 com.h2database:h2 更新为 2.0.206

如果这个文章对你有帮助,不要忘记 「在看」 「点赞」 「收藏」 三连啊喂!

7d43e0ff651c68366b06a7e5b48bd33d.png

2b46001f91b7d38abfb90561203c4f28.png

2022年全网首发|大数据专家级技能模型与学习指南(胜天半子篇)

互联网最坏的时代可能真的来了

我在B站读大学,大数据专业

我们在学习Flink的时候,到底在学习什么?

193篇文章暴揍Flink,这个合集你需要关注一下

Flink生产环境TOP难题与优化,阿里巴巴藏经阁YYDS

Flink CDC我吃定了耶稣也留不住他!| Flink CDC线上问题小盘点

我们在学习Spark的时候,到底在学习什么?

在所有Spark模块中,我愿称SparkSQL为最强!

硬刚Hive | 4万字基础调优面试小总结

数据治理方法论和实践小百科全书

标签体系下的用户画像建设小指南

4万字长文 | ClickHouse基础&实践&调优全视角解析

【面试&个人成长】2021年过半,社招和校招的经验之谈

大数据方向另一个十年开启 |《硬刚系列》第一版完结

我写过的关于成长/面试/职场进阶的文章

当我们在学习Hive的时候在学习什么?「硬刚Hive续集」

这篇关于卷起来了,Apache Flink 1.13.6 发布!的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1142613

相关文章

SpringKafka消息发布之KafkaTemplate与事务支持功能

《SpringKafka消息发布之KafkaTemplate与事务支持功能》通过本文介绍的基本用法、序列化选项、事务支持、错误处理和性能优化技术,开发者可以构建高效可靠的Kafka消息发布系统,事务支... 目录引言一、KafkaTemplate基础二、消息序列化三、事务支持机制四、错误处理与重试五、性能优

新特性抢先看! Ubuntu 25.04 Beta 发布:Linux 6.14 内核

《新特性抢先看!Ubuntu25.04Beta发布:Linux6.14内核》Canonical公司近日发布了Ubuntu25.04Beta版,这一版本被赋予了一个活泼的代号——“Plu... Canonical 昨日(3 月 27 日)放出了 Beta 版 Ubuntu 25.04 系统镜像,代号“Pluc

Nginx实现前端灰度发布

《Nginx实现前端灰度发布》灰度发布是一种重要的策略,它允许我们在不影响所有用户的情况下,逐步推出新功能或更新,通过灰度发布,我们可以测试新版本的稳定性和性能,下面就来介绍一下前端灰度发布的使用,感... 目录前言一、基于权重的流量分配二、基于 Cookie 的分流三、基于请求头的分流四、基于请求参数的分

使用Apache POI在Java中实现Excel单元格的合并

《使用ApachePOI在Java中实现Excel单元格的合并》在日常工作中,Excel是一个不可或缺的工具,尤其是在处理大量数据时,本文将介绍如何使用ApachePOI库在Java中实现Excel... 目录工具类介绍工具类代码调用示例依赖配置总结在日常工作中,Excel 是一个不可或缺的工http://

Apache伪静态(Rewrite).htaccess文件详解与配置技巧

《Apache伪静态(Rewrite).htaccess文件详解与配置技巧》Apache伪静态(Rewrite).htaccess是一个纯文本文件,它里面存放着Apache服务器配置相关的指令,主要的... 一、.htAccess的基本作用.htaccess是一个纯文本文件,它里面存放着Apache服务器

Debezium 与 Apache Kafka 的集成方式步骤详解

《Debezium与ApacheKafka的集成方式步骤详解》本文详细介绍了如何将Debezium与ApacheKafka集成,包括集成概述、步骤、注意事项等,通过KafkaConnect,D... 目录一、集成概述二、集成步骤1. 准备 Kafka 环境2. 配置 Kafka Connect3. 安装 D

定价129元!支持双频 Wi-Fi 5的华为AX1路由器发布

《定价129元!支持双频Wi-Fi5的华为AX1路由器发布》华为上周推出了其最新的入门级Wi-Fi5路由器——华为路由AX1,建议零售价129元,这款路由器配置如何?详细请看下文介... 华为 Wi-Fi 5 路由 AX1 已正式开售,新品支持双频 1200 兆、配有四个千兆网口、提供可视化智能诊断功能,建

深入理解Apache Airflow 调度器(最新推荐)

《深入理解ApacheAirflow调度器(最新推荐)》ApacheAirflow调度器是数据管道管理系统的关键组件,负责编排dag中任务的执行,通过理解调度器的角色和工作方式,正确配置调度器,并... 目录什么是Airflow 调度器?Airflow 调度器工作机制配置Airflow调度器调优及优化建议最

SpringBoot使用Apache Tika检测敏感信息

《SpringBoot使用ApacheTika检测敏感信息》ApacheTika是一个功能强大的内容分析工具,它能够从多种文件格式中提取文本、元数据以及其他结构化信息,下面我们来看看如何使用Ap... 目录Tika 主要特性1. 多格式支持2. 自动文件类型检测3. 文本和元数据提取4. 支持 OCR(光学

五大特性引领创新! 深度操作系统 deepin 25 Preview预览版发布

《五大特性引领创新!深度操作系统deepin25Preview预览版发布》今日,深度操作系统正式推出deepin25Preview版本,该版本集成了五大核心特性:磐石系统、全新DDE、Tr... 深度操作系统今日发布了 deepin 25 Preview,新版本囊括五大特性:磐石系统、全新 DDE、Tree