学习学习
从一例状态引发的性能问题谈Flink状态序列化前言 好久不见（鞠躬 最近处在转型期，每天忙到飞起，关注具体技术细节的精力自然就比较少了（上一篇许下的周更承诺也食言了 = =）。上周帮助他人快速解决了一个因误用Flink状...
发简信
IP属地：广东
-
-
大佬您好，想有偿邀请您来我司做Flink知识和具体场景应用的培训，如果您有意向的话，麻烦简信回我一下，这里好像留不了邮箱。谢谢。
Hudi Timeline简析
前言 Long time no see（鞠躬 最近终于开始尝试推广Hudi在部门内部的应用，作为流批一体计划的最后一块拼图，顺便复活许久未更的博客，希望今后至少能保持周更的节...
-
详解JVM堆外内存的分配和回收机制前言 写这篇文章的契机是前段时间在Flink社区大群里详细解答了一个问题。 我们每天都会与JVM堆打交道（之前哪篇文章的开头也是这个来着）。但作为大数据工程师，我们对JVM的...
-
Https原理及流程原文地址我们知道，HTTP请求都是明文传输的，所谓的明文指的是没有经过加密的信息，如果HTTP请求被黑客拦截，并且里面含有银行卡密码等敏感数据的话，会非常危险。为了解决这个问...
-
大大您好，目前有成熟开源的产品可以解析Flink sql这块血缘么。还是需要学习Calcite解析Flink SQL之间的血缘关系？
基于Calcite解析Flink SQL列级数据血缘
数据血缘 数据血缘（data lineage）是数据治理（data governance）的重要组成部分，也是元数据管理、数据质量管理的有力工具。通俗地讲，数据血缘就是数据在...
-
浅谈Flink的基石——Google Dataflow模型前言 最近正在深入地研究与重度使用Flink，中途了解到它实际上就是Google Dataflow模型的一种implementation。我是个喜欢刨根问底的人，于是就阅读了...
-
大佬是FFA哪位呀。哈哈
浅谈Flink SQL代码生成与UDF重复调用的优化
前言 之前讲解Flink SQL执行流程时留下了代码生成的坑，在百忙之中抽时间补一补。 代码生成简介 代码生成（code generation）是当今各种数据库和数据处理引擎...
-
@LittleMagic 大大您好。请问如果想学习Flink sql解析生成逻辑执行计划，后生成物理执行计划再到JobGraph这块过程应该怎么系统学习。直接看源码感觉效率有点低，因为我们想做一个平台，支持用户输入flink sql进行作业提交。
使Flink SQL Kafka Source支持独立设置并行度
前言 社区在Flink 1.12版本通过FLIP-146[https://cwiki.apache.org/confluence/display/FLINK/FLIP-146...
-
从Flink SQL "doesn't support consuming update and delete changes" 错误谈起
前言 相信我们在初学Flink SQL时，多少遇到过像这样的错误信息： 为什么有些下游算子不能接受上游算子发来的UPDATE和DELETE消息呢？本文以1.13版本为准来简单...
-
打卡学习😄
使Flink SQL Kafka Source支持独立设置并行度
前言 社区在Flink 1.12版本通过FLIP-146[https://cwiki.apache.org/confluence/display/FLINK/FLIP-146...
-
使Flink SQL Kafka Source支持独立设置并行度前言 社区在Flink 1.12版本通过FLIP-146[https://cwiki.apache.org/confluence/display/FLINK/FLIP-146...
-
通过源码理解Java类加载机制与双亲委派模型前言 在JVM中，类加载的过程分为加载、链接（验证、准备、解析）、初始化5个阶段。而加载阶段需要完成的重要事项之一，就是通过一个类的全限定名来获取定义此类的二进制字节码流（在...
-
利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏前言 虽然笔者之前写过基于Prometheus PushGateway搭建Flink监控的过程，但是在我们的生产环境中，使用的是InfluxDB。InfluxDB是一个由Go...
-
哇。又发现一篇好文章。
详解分布式共识（一致性）算法Raft
分布式共识及Raft简介 所谓分布式共识（consensus），与CAP理论[https://en.wikipedia.org/wiki/CAP_theorem]中的一致性（...
-
跟着大佬脚步学习
Flink SQL窗口表值函数（Window TVF）聚合实现原理浅析
引子 表值函数（table-valued function, TVF），顾名思义就是指返回值是一张表的函数，在Oracle、SQL Server等数据库中屡见不鲜。而在Fli...
-
Flink SQL窗口表值函数（Window TVF）聚合实现原理浅析引子 表值函数（table-valued function, TVF），顾名思义就是指返回值是一张表的函数，在Oracle、SQL Server等数据库中屡见不鲜。而在Fli...
-
学习学习
From Calcite to Tampering with Flink SQL
今天为组内同学做了题为「From Calcite to Tampering with Flink SQL」的分享，将Markdown版讲义贴在下面。 本次分享信息量极大，涵盖...
-
-
从AggregateFunction.merge()到Flink会话窗口实现原理前言 在我们使用Flink DataStream API编写业务代码时，aggregate()算子和AggregateFunction无疑是非常常用的。编写一个Aggrega...
-
跟着大佬博客学习太爽了，打卡
从AggregateFunction.merge()到Flink会话窗口实现原理
前言 在我们使用Flink DataStream API编写业务代码时，aggregate()算子和AggregateFunction无疑是非常常用的。编写一个Aggrega...
