在 Flink 1.10 的 Table API 和 SQL 中，表支持的格式有四种： 官网地址如下：https://ci.apache.org/projects/flink/flin ...

最近因为疫情的原因，偷了好长时间的懒，现在终于开始继续看Flink 的SQL 了 ———————————————— 电脑上的Flink 项目早就升级到了 1.10了，最近还在看官网新的文档，趁着 ...

　　Flink 统计当日的UV、PV 　　测试环境： 　　　　flink 1.7.2 　　1、数据流程 　　　　 　　　　a.模拟数据生成，发送到kafka（json 格式）　　 　　　　 ...

Flink 1.11 发布了支持 MySQL CDC（Changelog Data Capture） 可以直接解析 Canal / Debezium 格式的 MySQL Binlog 对于实时处理程 ...

Flink 1.11 版本对SQL的优化是很多的，其中最重要的一点就是 hive 功能的完善，不再只是作为持久化的 Catalog，而是可以用原生的 Flink SQL 流式的写数据到入 hive中 ...

　　接上篇：【翻译】Flink 异步I / O访问外部数据 　　最近看了大佬的博客，突然想起Async I/O方式是Blink 推给社区的一大重要功能，可以使用异步的方式获取外部数据，想着自己实现以 ...

社区中有好几个同学问过这样的场景：　　 这里假设一个 ETL 的场景，输入数据包含两个字段 “type, userid....” ，需要根据 type，连接一张 mysql 的配置表， ...

接上篇：Flink FileSink 自定义输出路径——BucketingSink 上篇使用BucketingSink 实现了自定义输出路径，现在来看看 StreamingFileSink( 据说 ...

先上代码： 直接上报错信息： 报错信息是找不到合适的table factory，查询报错类TableFactoryService.scala 源码214行（ ...

参考： 官网协议介绍：http://kafka.apache.org/protocol.html#The_Messages_Fetch kafka协议兼容性 http://www.cnblogs ...