Flink 1.10 Native Kubernetes 原理与实践

千呼万唤始出来,在 Kubernetes 如火如荼的今天,Flink 社区终于在 1.10 版本提供了对 Kubernetes 的原生支持,也就是 Native Kubernetes Integration。不过还只是Beta版本,预计会在 1.11 版本里面提供完整的支持。

阅读全文

Flink on Yarn / Kubernetes 原理剖析及实践

本文是我参加 Apache Flink China 社区钉钉群直播的教程(进阶篇 2.4)。我稍作调整后发在个人网站(zhoukaibo.com)上。

阅读全文

Apache Flink 客户端操作

本文是我参加 Apache Flink China 社区钉钉群直播的教程(基础篇 1.5)。我稍作调整后发在个人网站(zhoukaibo.com)上。

阅读全文

Java SPI 机制分析及其优缺点

SPI 概述

SPI 全称为(Service Provider Interface),是 JDK 内置的一种服务发现机制。它可以动态的为某个接口寻找服务实现,有点类似 IOC(Inversion of Control)的思想,将装配的控制权移到程序之外,在模块化设计中这个机制尤其重要。

阅读全文

谈谈流计算中的『Exactly Once』特性

本文翻译自 streaml.io 网站上的一篇博文:“Exactly once is NOT exactly the same” ,分析了流计算系统中常说的『Exactly Once』特性,主要观点是:『精确一次』并不保证是完全一样。

阅读全文

Apache Flink结合Kafka构建端到端的Exactly-Once处理

本文翻译自:https://data-artisans.com/blog/end-to-end-exactly-once-processing-apache-flink-apache-kafka

阅读全文

Hello World

Hello World!

2019年1月。

阅读全文