本文讲述了Flink和StreamPark自定义UDF函数的使用

本文讲述了Flink Parallelism、Flink Slot的关系

Kafka配置SASL_SSL认证传输加密

经过对SP的源码解读，发现SP对Flink的Metric等信息的监控分为两种实现方式，在K8S模式下获取的方式和其他方式有所区别，且K8S模式下为scala代码实现，其他模式为java代码实现，不过最终都是从Flink Web UI中获取数据，下文将对两种方式分别进行源码解读。