包含标签:flink 的文章
-
Flink迷你集群及默认参数简单介绍:
Flink迷你集群是一个轻量级的本地集群,可用于在本地环境中快速开发和测试Flink应用程序。迷你集群不需要任何复杂的配置和管理,只需要提供一个简单的配置即…… -
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 的方案推广大概已经有了一年半的时…… -
-
网易游戏 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……