公众号文章都在个人博客网站：https://www.ikeguang.com/ 同步，欢迎访问。 最近看到有人在用flink sql的页面管理平台，大致看了下，尝试安装使用，比原生的flink sql界面确实好用多了，我们看下原生的，通过bin/sql-client.sh命令进入那个黑框，一只松鼠，对，就是那个界面。。。。 这个工具不是Flink官方出的，是一个国内的小伙伴写的，Github地址： https://github.com/zhp8341/flink-streaming-platform-web 根据g…
公众号文章都在个人博客网站：https://www.ikeguang.com/ 同步，欢迎访问。 业务需要一种OLAP引擎，可以做到实时写入存储和查询计算功能，提供高效、稳健的实时数据服务，最终决定ClickHouse 什么是ClickHouse？ ClickHouse是一个用于联机分析(OLAP)的列式数据库管理系统(DBMS)。 列式数据库更适合于OLAP场景(对于大多数查询而言，处理速度至少提高了100倍)，下面详细解释了原因(通过图片更有利于直观理解)，图片来源于ClickHouse中文官方文档。 行式 列…
本文首发于我的个人博客网站 等待下一个秋-Flink 什么是CDC？ CDC是（Change Data Capture 变更数据获取）的简称。核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 1. 环境准备 mysql Hive flink 1.13.5 on yarn 说明：如果没有安装hadoop，那么可以不用yarn，直接用flink standalone环境吧…
本文首发于我的个人博客网站 等待下一个秋-Flink 什么是CDC？ CDC是（Change Data Capture 变更数据获取）的简称。核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 1. 环境准备 mysql hbase flink 1.13.5 on yarn 说明：如果没有安装hadoop，那么可以不用yarn，直接用flink standalone环境…
本文首发于我的个人博客网站 等待下一个秋-Flink 什么是CDC？ CDC是（Change Data Capture 变更数据获取）的简称。核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 1. 环境准备 mysql kafka 2.3 flink 1.13.5 on yarn 说明：如果没有安装hadoop，那么可以不用yarn，直接用flink standalo…
本文首发于我的个人博客网站 等待下一个秋-Flink 什么是CDC？ CDC是（Change Data Capture 变更数据获取）的简称。核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 1. 环境准备 mysql elasticsearch flink on yarn 说明：如果没有安装hadoop，那么可以不用yarn，直接用flink standalone环…
Flink系列文章 第01讲：Flink 的应用场景和架构模型 第02讲：Flink 入门程序 WordCount 和 SQL 实现 第03讲：Flink 的编程模型与其他框架比较 第04讲：Flink 常用的 DataSet 和 DataStream API 第05讲：Flink SQL & Table 编程和案例 第06讲：Flink 集群安装部署和 HA 配置 第07讲：Flink 常见核心概念分析 第08讲：Flink 窗口、时间和水印 第09讲：Flink 状态与容错 第10讲：Flink Sid…
Flink系列文章 第01讲：Flink 的应用场景和架构模型 第02讲：Flink 入门程序 WordCount 和 SQL 实现 第03讲：Flink 的编程模型与其他框架比较 第04讲：Flink 常用的 DataSet 和 DataStream API 第05讲：Flink SQL & Table 编程和案例 第06讲：Flink 集群安装部署和 HA 配置 第07讲：Flink 常见核心概念分析 第08讲：Flink 窗口、时间和水印 第09讲：Flink 状态与容错 第10讲：Flink Sid…
Flink系列文章 第01讲：Flink 的应用场景和架构模型 第02讲：Flink 入门程序 WordCount 和 SQL 实现 第03讲：Flink 的编程模型与其他框架比较 第04讲：Flink 常用的 DataSet 和 DataStream API 第05讲：Flink SQL & Table 编程和案例 第06讲：Flink 集群安装部署和 HA 配置 第07讲：Flink 常见核心概念分析 第08讲：Flink 窗口、时间和水印 第09讲：Flink 状态与容错 第10讲：Flink Sid…
Flink系列文章 第01讲：Flink 的应用场景和架构模型 第02讲：Flink 入门程序 WordCount 和 SQL 实现 第03讲：Flink 的编程模型与其他框架比较 第04讲：Flink 常用的 DataSet 和 DataStream API 第05讲：Flink SQL & Table 编程和案例 第06讲：Flink 集群安装部署和 HA 配置 第07讲：Flink 常见核心概念分析 第08讲：Flink 窗口、时间和水印 第09讲：Flink 状态与容错 第10讲：Flink Sid…
