准备工作

安装查看 Java 的版本号,推荐使用 Java 8。

安装 Flink

在 Mac OS X 上安装 Flink 是非常方便的。推荐通过 homebrew 来安装。

1brew install apache-flink

检查安装:

1flink --version

结果:

1Version: 1.6.0, Commit ID: ff472b4

启动 flink

1zhisheng@zhisheng  /usr/local/Cellar/apache-flink/1.6.0/libexec/bin  ./start-cluster.sh
2Starting cluster.
3Starting standalonesession daemon on host zhisheng.
4Starting taskexecutor daemon on host zhisheng.

接着就可以进入 web 页面(http://localhost:8081/) 查看

demo

1、新建一个 maven 项目

Flink从入门到精通100篇(一)-如何在Mac 上搭建 Flink环境并做简单测试相关推荐

  1. Flink从入门到精通100篇(二十四)-对Flink SQL Client 源码做深度解析

    前言 本文基于 Flink 1.12-SNAPSHOT,使用sql client命令行提交insert语句进行整个流程的分析. sql-client.sh embedded --update &quo ...

  2. Flink从入门到精通100篇(二十二)-Apache Flink OLAP引擎性能优化及应用

    前言 本次分享的主题为Apache Flink新场景--OLAP引擎,主要内容包括: 背景介绍 Apache Flink OLAP引擎 案例介绍 未来计划 1. OLAP及其分类 OLAP是一种让用户 ...

  3. Flink从入门到精通100篇(二十三)-基于Apache Flink的爱奇艺实时计算平台建设实践

    前言 随着大数据的快速发展,行业大数据服务越来越重要.同时,对大数据实时计算的要求也越来越高.今天会和大家分享下爱奇艺基于Apache Flink的实时计算平台建设实践. 今天的介绍会围绕下面三点展开 ...

  4. Flink从入门到精通100篇(二十一)-万字长文详解 Flink 中的 CopyOnWriteStateTable

    前言 现如今想阅读 HashMap 源码实际上比较简单,因为网上一大堆博客去分析 HashMap 和 ConcurrentHashMap.本文详细分析 CopyOnWriteStateTable 源码 ...

  5. Flink从入门到精通100篇(二十一)-Flink 状态(State)管理在推荐场景中的应用

    前言 Flink作为纯流式大数据实时计算引擎,较于Spark Streaming的微批处理引擎,不管是内存管理,多流合并,还是时间窗口,迭代处理上,Flink在实时计算场景更较适合.而Flink的St ...

  6. Flink从入门到精通100篇(三)-如何利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏环境

    前言 虽然博主之前写过基于Prometheus PushGateway搭建Flink监控的过程,但是在我们的生产环境中,使用的是InfluxDB.InfluxDB是一个由Go语言写成的.由Influx ...

  7. Flink从入门到精通100篇(十三)-Flink的入门教学

    前言 Flink 是一种流式计算框架,为什么我会接触到 Flink 呢?因为我目前在负责的是监控平台的告警部分,负责采集到的监控数据会直接往 kafka 里塞,然后告警这边需要从 kafka topi ...

  8. Flink从入门到精通100篇(二十三)-Flink实战应用案例:如何清理过期的 Checkpoint 目录?

    目录 Flink Checkpoint 目录的清除策略 生产环境应该选择哪种清除策略 生产环境必须定期脚本清理 Checkpoint 和 Savepoint 目录 RocksDB 增量 Checkpo ...

  9. Flink从入门到精通100篇(二十二)- Flink应用实战案例:如何实现网络流控与反压机制

    目录 Flink 流处理为什么需要网络流控? Flink V1.5 版之前网络流控介绍 Flink V1.5 版之前的反压策略存在的问题 Credit的反压策略实现原理,Credit是如何解决 Fli ...

最新文章

  1. 为什么颜值越来越重要_看脸时代来了吗?为什么这个时代越来越注重颜值?
  2. win10终端仿真程序_win10下子系统的使用
  3. sharepoint 2010 如何使用sharepoint多媒体视频播放media webpart功能
  4. TCP滑动窗口(Sliding Window)原理
  5. UA MATH567 高维统计 专题1 Supervised PCA Regression概述
  6. Python必备知识点:对Json的基本使用方法
  7. Springboot利用poi导出excel下载
  8. 求职招聘市场复苏!市场平均薪资超8000元
  9. Linux中的sed命令,使用方法之一「替换字符串中的内容 」,以及「s/ / / 」和「s/ / /g」之间的区别
  10. 强化学习 —— gym
  11. POJ2456-Aggressive cows
  12. linux命令执行绕过,命令执行绕过
  13. 基于Java实现的免疫算法-克隆选择算法
  14. 计算机基础知识题二,计算机基础知识题库(五)
  15. 人工智能核心能力包括哪些层面?
  16. Android不透明度16进制值
  17. C++面向对象课程设计报告_快递系统
  18. JPA Native Query(本地查询)及查询结果转换
  19. 搭建文字转语音(TTS)服务器
  20. 《HelloGitHub》第 79 期

热门文章

  1. 网页插件学javascript还是jquery好啊?
  2. 邮件办公系统Exchange
  3. AcWing 845. 八数码(3阶数字华容道):bfs求最短路,状态表示困难
  4. 军用软件概算计价规范_超强干货分享:547建筑工程计量与计价,帮你轻松掌握计量与计价...
  5. python import gc_Python 2.6 GC似乎可以清理对象,但不会释放内存
  6. java console 交互_实例讲解java中Console类的用法
  7. python判断实例的类型
  8. linux 系统时间是在哪里记录的,Linux系统如何记录时间
  9. 双任务延时原理与空闲任务
  10. 音频在计算机中的存储