最新 最热

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(一)案例需求

腾讯云开发者社区是腾讯云官方开发者社区,致力于打造开发者的技术分享型社区。提供专栏,问答,沙龙等产品和服务,汇聚海量精品云计算使用和开发经验,致力于帮助开发者快速成长与发展,营造开放的云计算技术生态圈。...

2023-10-17
0

全网最详细4W字Flink入门笔记(下)

Flink是一个有状态的流式计算引擎,所以会将中间计算结果(状态)进行保存,默认保存到TaskManager的堆内存中,但是当task挂掉,那么这个task所对应的状态都会被清空,造成了数据丢失,无法保证结果的正确性,哪怕想要得到正确结果,所...

2023-10-16
0

全网最详细4W字Flink入门笔记(上)

因为公司用到大数据技术栈的缘故,离线用的是Spark,实时用的是Flink,所以这篇文章是关于Flink的,这篇文章对Flink的相关概念介绍的比较全面,希望对大家学习Flink能有所帮助。...

2023-10-16
0

构建智能电商推荐系统:大数据实战中的Kudu、Flink和Mahout应用【上进小菜猪大数据】

本文将介绍如何利用Kudu、Flink和Mahout这三种技术构建一个强大的大数据分析平台。我们将详细讨论这些技术的特点和优势,并提供代码示例,帮助读者了解如何在实际项目中应用它们。通过本文的指导,读者将能够掌握如何使用...

2023-10-16
0

超越大数据的边界:Apache Flink实战解析【上进小菜猪大数据系列】

Apache Flink是一种快速、可靠、可扩展的开源流处理框架,被广泛应用于大数据领域。本文将介绍Apache Flink的实战运用,包括其核心概念、架构设计以及基于Flink进行大数据流处理的具体示例。通过代码实现的案例,读者将深...

2023-10-16
0

Flink exactly-once系列实践之KafkaToKafka

注意事项:这里使用的是本地FSstateBackend,注意你的路径的设置,以hdfs://或者file://为地址标识符,否则Flink的文件系统将无法识别。

2023-09-18
0

java 17运行jar报错:java.lang.UnsatisfiedLinkError: Can't load library:

The following packages were automatically installed and are no longer required:

2023-09-17
0

Flink Checkpoint/Savepoint对比

Flink 为作业的容错提供 Checkpoint 和 Savepoint 两种机制。保存点机制(Savepoints)是检查点机制一种特殊的实现,它允许你通过手工方式来触发Checkpoint,并将结果持久化存储到指定路径中,主要用于避免Flink集群在重启或升...

2023-09-17
0

零距离接触Flink:全面解读流计算框架入门与实操指南

Apache Flink作为开源的分布式流处理框架,受到了广泛的关注和应用。本文将分享如何从零开始搭建一个Flink运行环境,并在其上运行一个“WordCount”的例子程序。...

2023-09-14
0

【Flink实战】新老用户方案优化使用状态与布隆过滤器的方式

腾讯云开发者社区是腾讯云官方开发者社区,致力于打造开发者的技术分享型社区。提供专栏,问答,沙龙等产品和服务,汇聚海量精品云计算使用和开发经验,致力于帮助开发者快速成长与发展,营造开放的云计算技术生态圈。...

2023-09-14
0