- source端（kafka consumer） 偏移量保存下来，如果后续任务出现了故障，恢复的时候可以由连接器重置偏移量，重新消费数据，保证一致性。 -内部(checkpoint 机制) 基于 Chandy-Lamport 算法的...

原标题：通俗易懂的介绍阿里云、大数据和云计算，内附阿里内部资料 阿里云：数据上云的平台，比如你家有小银子，但是存在家里诸多不便，于是你把它存进银行拿到了一个存款折子，这里的银行就类...

原标题：详解 Flink Catalog 在 ChunJun 中的实践之路 我们知道 Flink 有Table（表）、View（视图）、Function（函数/算子）、Database（数据库）的概念，相对于这些耳熟能详的概念，Flink 里还...

作者：黄婧 ChatGPT的诞生，在全球掀起了新一轮的人工智能风暴。AI对于大众而言不再是飘在空中的虚幻的楼阁，而是可以看见清晰应用图景的未来之窗。 ChatGPT的火爆也引发国内大型科技企业争相逐...

近段时间，由于公司项目的相关需求，需要对Flink做详细的梳理，我把学习过程整理成Flink详解系列的10篇左右的总结，供大家参考。 大数据计算引擎的发展 近年来随着大数据的发展，涌现出了一大批...

Apache Flink社群发布机器学习函数库Flink ML 2.0.0，在这个新版本中，开发团队重构Flink ML早期的函数库，扩展Flink ML API并更新Runtime主要功能，像是开始支持多输入和多输出，和添加流媒体...