zhisheng

4

Flink 全网最全资源（视频、博客、PPT、入门、实战、源码解析、问答等持续更新）

• zhisheng   2019-06-03 发布
• 3 收藏

Flink 学习项目代码 [链接] [链接] 麻烦路过的各位亲给这个项目点个 star，太不易了，写了这么多，算是对我坚持下来的一种鼓励吧！ 本项目结构 博客 1、Flink 从0到1学习 —— Apache Flink 介绍 2、Flink 从0到1学...

0

从0到1学习Flink》—— 你上传的 jar 包藏到哪里去了?

• zhisheng   2019-03-19 发布
• 收藏

这个问题其实我自己也有问过，但是自己因为自己的问题没有啥压力也就没深入去思考，现在可是知识星球的付费小伙伴问的，所以自然要逼着自己去深入然后才能给出正确的答案。

6

假如我是面试官，我会这样虐你

• zhisheng   2019-03-08 发布
• 6 收藏

又是金三银四的时候，我希望这份面试题能够祝你一臂之力！ 自我和项目相关 1、自我介绍 2、你觉得自己的优点是？你觉得自己有啥缺点？ 3、你有哪些 offer？ 4、你为什么要离开上家公司？你上家公司在xxx，我们公...

1

Blink 真香

• zhisheng   2019-03-01 发布
• 1 收藏

Blink 开源了有一段时间了，竟然没发现有人写相关的博客，其实我已经在我的知识星球里开始写了，今天来看看 Blink 为什么香？ 我们先看看 Blink 黑色版本： 对比下 Flink 版本你就知道黑色版本多好看了。 你上传 ...

1

《从0到1学习Flink》—— Flink 读取 Kafka 数据批量写入到 MySQL

• zhisheng   2019-02-24 发布
• 收藏

之前其实在 《从0到1学习Flink》—— 如何自定义 Data Sink ？ 文章中其实已经写了点将数据写入到 MySQL，但是一些配置化的东西当时是写死的，不能够通用，最近知识星球里有朋友叫我: 写个从 kafka 中读取数据，经...

0

《从0到1学习Flink》—— Flink 写入数据到 ElasticSearch

• zhisheng   2019-01-18 发布
• 收藏

前言 前面 FLink 的文章中我们已经介绍了说 Flink 已经有很多自带的 Connector。 1、[《从0到1学习Flink》—— Data Source 介绍]([链接] 2、《从0到1学习Flink》—— Data Sink 介绍 其中包括了 Source 和 Sink 的，...

3

《从0到1学习Flink》—— Flink 写入数据到 Kafka

• zhisheng   2019-01-17 发布
• 1 收藏

之前文章 《从0到1学习Flink》—— Flink 写入数据到 ElasticSearch 写了如何将 Kafka 中的数据存储到 ElasticSearch 中，里面其实就已经用到了 Flink 自带的 Kafka source connector（FlinkKafkaConsumer）。存入...

6

《从0到1学习Flink》—— Flink 项目如何运行？

• zhisheng   2019-01-16 发布
• 6 收藏

之前写了不少 Flink 文章了，也有不少 demo，但是文章写的时候都是在本地直接运行 Main 类的 main 方法，其实 Flink 是支持在 UI 上上传 Flink Job 的 jar 包，然后运行得。最开始在第一篇 《从0到1学习Flink》——...

1

《从0到1学习Flink》—— 介绍Flink中的Stream Windows

• zhisheng   2019-01-15 发布
• 1 收藏

目前有许多数据分析的场景从批处理到流处理的演变， 虽然可以将批处理作为流处理的特殊情况来处理，但是分析无穷集的流数据通常需要思维方式的转变并且具有其自己的术语（例如，“windowing（窗口化）”、“at-least...

0

《从0到1学习Flink》—— Flink 中几种 Time 详解

• zhisheng   2019-01-14 发布
• 收藏

Flink 在流程序中支持不同的 Time 概念，就比如有 Processing Time、Event Time 和 Ingestion Time。

2

《从0到1学习Flink》—— Flink Data transformation(转换)

• zhisheng   2019-01-13 发布
• 收藏

前言 在第一篇介绍 Flink 的文章 《《从0到1学习Flink》—— Apache Flink 介绍》 中就说过 Flink 程序的结构 Flink 应用程序结构就是如上图所示： 1、Source: 数据源，Flink 在流处理和批处理上的 source 大概有 4...

0

《从0到1学习Flink》—— 如何自定义 Data Sink ？

• zhisheng   2018-11-13 发布
• 收藏

前篇文章 《从0到1学习Flink》—— Data Sink 介绍 介绍了 Flink Data Sink，也介绍了 Flink 自带的 Sink，那么如何自定义自己的 Sink 呢？这篇文章将写一个 demo 教大家将从 Kafka Source 的数据 Sink 到 MySQL 中...

0

《从0到1学习Flink》—— 如何自定义 Data Source ？

• zhisheng   2018-11-12 发布
• 收藏

在 《从0到1学习Flink》—— Data Source 介绍 文章中，我给大家介绍了 Flink Data Source 以及简短的介绍了一下自定义 Data Source，这篇文章更详细的介绍下，并写一个 demo 出来让大家理解。

3

《从0到1学习Flink》—— Data Sink 介绍

• zhisheng   2018-11-09 发布
• 2 收藏

前言 再上一篇文章中 《从0到1学习Flink》—— Data Source 介绍 讲解了 Flink Data Source ，那么这里就来讲讲 Flink Data Sink 吧。 首先 Sink 的意思是： 大概可以猜到了吧！Data sink 有点把数据存储下来（落库...

0

《从0到1学习Flink》—— Data Source 介绍

• zhisheng   2018-11-08 发布
• 收藏

Flink 做为一款流式计算框架，它可用来做批处理，即处理静态的数据集、历史的数据集；也可以用来做流处理，即实时的处理些实时数据流，实时的产生数据流结果，只要数据源源不断的过来，Flink 就能够一直计算下去...

1

《从0到1学习Flink》—— Flink 配置文件详解

• zhisheng   2018-11-07 发布
• 1 收藏

前面文章我们已经知道 Flink 是什么东西了，安装好 Flink 后，我们再来看下安装路径下的配置文件吧。 安装目录下主要有 flink-conf.yaml 配置、日志的配置文件、zk 配置、Flink SQL Client 配置。 flink-conf.yam...

0

《从0到1学习Flink》—— Mac 上搭建 Flink 1.6.0 环境并构建运行简单程序入门

• zhisheng   2018-11-06 发布
• 收藏

<!-- more --> 准备工作 1、安装查看 Java 的版本号，推荐使用 Java 8。 安装 Flink 2、在 Mac OS X 上安装 Flink 是非常方便的。推荐通过 homebrew 来安装。 {代码...} 3、检查安装： {代码...} 结果： {...

12

《从0到1学习Flink》—— Apache Flink 介绍

• zhisheng   2018-11-05 发布
• 8 收藏

Flink 是一种流式计算框架，为什么我会接触到 Flink 呢？因为我目前在负责的是监控平台的告警部分，负责采集到的监控数据会直接往 kafka 里塞，然后告警这边需要从 kafka topic 里面实时读取到监控数据，并将读取...

6

教你如何在 IDEA 远程 Debug ElasticSearch

• zhisheng   2018-08-29 发布
• 4 收藏

前提 之前在源码阅读环境搭建文章中写过我遇到的一个问题迟迟没有解决，也一直困扰着我。问题如下，在启动的时候解决掉其他异常和报错后，最后剩下这个错误一直解决不了： {代码...} 网上的解决办法也试了很多遍...

4

渣渣的 ElasticSearch 源码解析 —— 启动流程（下）

• zhisheng   2018-08-29 发布
• 3 收藏

上篇文章写完了 ES 流程启动的一部分，main 方法都入口，以及创建 Elasticsearch 运行的必须环境以及相关配置，接着就是创建该环境的节点了。