卷起来了,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

相关文章

MySQL数据库宕机,启动不起来,教你一招搞定!

作者介绍:老苏,10余年DBA工作运维经验,擅长Oracle、MySQL、PG、Mongodb数据库运维(如安装迁移,性能优化、故障应急处理等)公众号:老苏畅谈运维欢迎关注本人公众号,更多精彩与您分享。 MySQL数据库宕机,数据页损坏问题,启动不起来,该如何排查和解决,本文将为你说明具体的排查过程。 查看MySQL error日志 查看 MySQL error日志,排查哪个表(表空间

高效+灵活,万博智云全球发布AWS无代理跨云容灾方案!

摘要 近日,万博智云推出了基于AWS的无代理跨云容灾解决方案,并与拉丁美洲,中东,亚洲的合作伙伴面向全球开展了联合发布。这一方案以AWS应用环境为基础,将HyperBDR平台的高效、灵活和成本效益优势与无代理功能相结合,为全球企业带来实现了更便捷、经济的数据保护。 一、全球联合发布 9月2日,万博智云CEO Michael Wong在线上平台发布AWS无代理跨云容灾解决方案的阐述视频,介绍了

Vue3项目开发——新闻发布管理系统(六)

文章目录 八、首页设计开发1、页面设计2、登录访问拦截实现3、用户基本信息显示①封装用户基本信息获取接口②用户基本信息存储③用户基本信息调用④用户基本信息动态渲染 4、退出功能实现①注册点击事件②添加退出功能③数据清理 5、代码下载 八、首页设计开发 登录成功后,系统就进入了首页。接下来,也就进行首页的开发了。 1、页面设计 系统页面主要分为三部分,左侧为系统的菜单栏,右侧

用Unity2D制作一个人物,实现移动、跳起、人物静止和动起来时的动画:中(人物移动、跳起、静止动作)

上回我们学到创建一个地形和一个人物,今天我们实现一下人物实现移动和跳起,依次点击,我们准备创建一个C#文件 创建好我们点击进去,就会跳转到我们的Vision Studio,然后输入这些代码 using UnityEngine;public class Move : MonoBehaviour // 定义一个名为Move的类,继承自MonoBehaviour{private Rigidbo

maven发布项目到私服-snapshot快照库和release发布库的区别和作用及maven常用命令

maven发布项目到私服-snapshot快照库和release发布库的区别和作用及maven常用命令 在日常的工作中由于各种原因,会出现这样一种情况,某些项目并没有打包至mvnrepository。如果采用原始直接打包放到lib目录的方式进行处理,便对项目的管理带来一些不必要的麻烦。例如版本升级后需要重新打包并,替换原有jar包等等一些额外的工作量和麻烦。为了避免这些不必要的麻烦,通常我们

禅道Docker安装包发布

禅道Docker安装包发布 大家好, 禅道Docker安装包发布。 一、下载地址 禅道开源版:   /dl/zentao/docker/docker_zentao.zip  备用下载地址:https://download.csdn.net/download/u013490585/16271485 数据库用户名: root,默认密码: 123456。运行时,可以设置 MYSQL_ROOT_P

Flink任务重启策略

概述 Flink支持不同的重启策略,以在故障发生时控制作业如何重启集群在启动时会伴随一个默认的重启策略,在没有定义具体重启策略时会使用该默认策略。如果在工作提交时指定了一个重启策略,该策略会覆盖集群的默认策略默认的重启策略可以通过 Flink 的配置文件 flink-conf.yaml 指定。配置参数 restart-strategy 定义了哪个策略被使用。常用的重启策略: 固定间隔 (Fixe

Apache Tiles 布局管理器

陈科肇 =========== 1.简介 一个免费的开源模板框架现代Java应用程序。  基于该复合图案它是建立以简化的用户界面的开发。 对于复杂的网站,它仍然最简单,最优雅的方式来一起工作的任何MVC技术。 Tiles允许作者定义页面片段可被组装成在运行一个完整的网页。  这些片段,或Tiles,可以用于为了降低公共页面元素的重复,简单地包括或嵌入在其它瓦片,制定了一系列可重复使用

Apache HttpClient使用详解

转载地址:http://eksliang.iteye.com/blog/2191017 Http协议的重要性相信不用我多说了,HttpClient相比传统JDK自带的URLConnection,增加了易用性和灵活性(具体区别,日后我们再讨论),它不仅是客户端发送Http请求变得容易,而且也方便了开发人员测试接口(基于Http协议的),即提高了开发的效率,也方便提高代码的健壮性。因此熟

C++编程:ZeroMQ进程间(订阅-发布)通信配置优化

文章目录 0. 概述1. 发布者同步发送(pub)与订阅者异步接收(sub)示例代码可能的副作用: 2. 适度增加缓存和队列示例代码副作用: 3. 动态的IPC通道管理示例代码副作用: 4. 接收消息的超时设置示例代码副作用: 5. 增加I/O线程数量示例代码副作用: 6. 异步消息发送(使用`dontwait`标志)示例代码副作用: 7. 其他可以考虑的优化项7.1 立即发送(ZMQ_IM