LittleMagic

前言 写这篇文章的契机是前段时间在Flink社区大群里详细解答了一个问题。 我们每天都会与JVM堆打交道（之前哪篇文章的开头也是这个来着）。但作为大数据工程师，我们对JVM的...

Leon_hy

原文地址我们知道，HTTP请求都是明文传输的，所谓的明文指的是没有经过加密的信息，如果HTTP请求被黑客拦截，并且里面含有银行卡密码等敏感数据的话，会非常危险。为了解决这个问...

LittleMagic

前言 最近正在深入地研究与重度使用Flink，中途了解到它实际上就是Google Dataflow模型的一种implementation。我是个喜欢刨根问底的人，于是就阅读了...

LittleMagic

前言 社区在Flink 1.12版本通过FLIP-146[https://cwiki.apache.org/confluence/display/FLINK/FLIP-146...

LittleMagic

前言 在JVM中，类加载的过程分为加载、链接（验证、准备、解析）、初始化5个阶段。而加载阶段需要完成的重要事项之一，就是通过一个类的全限定名来获取定义此类的二进制字节码流（在...

LittleMagic

前言 虽然笔者之前写过基于Prometheus PushGateway搭建Flink监控的过程，但是在我们的生产环境中，使用的是InfluxDB。InfluxDB是一个由Go...

LittleMagic

引子 表值函数（table-valued function, TVF），顾名思义就是指返回值是一张表的函数，在Oracle、SQL Server等数据库中屡见不鲜。而在Fli...

LittleMagic

前言 在我们使用Flink DataStream API编写业务代码时，aggregate()算子和AggregateFunction无疑是非常常用的。编写一个Aggrega...