包含标签：flink 的文章
-
Flink迷你集群及默认参数简单介绍：
Flink迷你集群是一个轻量级的本地集群，可用于在本地环境中快速开发和测试Flink应用程序。迷你集群不需要任何复杂的配置和管理，只需要提供一个简单的配置即……admin 前天
-
Flink CDC 最佳实践（以 MySQL 为例）
1. 准备工作 1.1 确认 MySQL binlog 模式 确认 MySQL 数据库的 binlog 模式是否为 ROW。可以在 MySQL 命令行中执行以下语句确认： SHOW GLOBAL VARIABLES LIK…… -
Flink 优化(六) ——— FlinkSQL 调优
目录 一、设置空闲状态保留时间 二、开启 MiniBatch 三、开启 LocalGlobal 四、开启 Split Distinct 五、多维 DISTINCT 使用 Filter 六、设置参数总结 F…… -
实时数据湖 Flink Hudi 实践探索
导读： 首先做个自我介绍，我目前在阿里云云计算平台，从事研究 Flink 和 Hudi 结合方向的相关工作。 目前，Flink + Hudi 的方案推广大概已经有了一年半的时…… -
我眼中的大数据（一）
前言 在正式落地谈技术之前，先花一些篇幅说说大数据技术的发展史。我们常说的大数据技术，其实起源于Google在2004年前后发表的三篇论文，分别是分布式文件系…… -
网易游戏 Flink SQL 平台化实践
摘要：本文整理自网易游戏资深开发工程师林小铂在 Flink Forward Asia 2021 平台建设专场的演讲。主要内容包括： 网易游戏 Flink SQL 发展历程 基于模板 ja…… -
【flink on yarn】/root/.flink/application_xxxxx/force-shading-1.9.1.jar does not exist
1.背景 启动脚本大致内容如下： 直接sh 执行这个脚本能正常拉起 但crontab -e配置这个脚本定时执行后报下面的错误： 2.原因分析 crontab 执行时没有加载到/…… -
Flink(scala)整合MySQL统计UV(unique visitor)
数据源是尚硅谷的课件, 需要的话可以私信我 核心代码 import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink.confi…… -
实时数仓与离线数仓架构对比、Flink消费流程
实时数仓架构图： 离线数仓： 与离线数仓区别： MySQL业务数据采集改用FlinkCDC;FlinkCDC与Maxwell处理方式和Cannal一样通过监控binlog方式（行级别），…… -
Flink使用KafkaSource从Kafka消息队列中读取数据
Flink使用KafkaSource从Kafka消息队列中读取数据 使用KafkaSource从Kafka消息队列中读取数据 1.KafkaSource创建的DataStream是一个并行的DataStream 2.KafkaS……