Flink从入门到精通100篇(一)-如何在Mac 上搭建 Flink环境并做简单测试
准备工作
安装查看 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环境并做简单测试相关推荐
- Flink从入门到精通100篇(二十四)-对Flink SQL Client 源码做深度解析
前言 本文基于 Flink 1.12-SNAPSHOT,使用sql client命令行提交insert语句进行整个流程的分析. sql-client.sh embedded --update &quo ...
- Flink从入门到精通100篇(二十二)-Apache Flink OLAP引擎性能优化及应用
前言 本次分享的主题为Apache Flink新场景--OLAP引擎,主要内容包括: 背景介绍 Apache Flink OLAP引擎 案例介绍 未来计划 1. OLAP及其分类 OLAP是一种让用户 ...
- Flink从入门到精通100篇(二十三)-基于Apache Flink的爱奇艺实时计算平台建设实践
前言 随着大数据的快速发展,行业大数据服务越来越重要.同时,对大数据实时计算的要求也越来越高.今天会和大家分享下爱奇艺基于Apache Flink的实时计算平台建设实践. 今天的介绍会围绕下面三点展开 ...
- Flink从入门到精通100篇(二十一)-万字长文详解 Flink 中的 CopyOnWriteStateTable
前言 现如今想阅读 HashMap 源码实际上比较简单,因为网上一大堆博客去分析 HashMap 和 ConcurrentHashMap.本文详细分析 CopyOnWriteStateTable 源码 ...
- Flink从入门到精通100篇(二十一)-Flink 状态(State)管理在推荐场景中的应用
前言 Flink作为纯流式大数据实时计算引擎,较于Spark Streaming的微批处理引擎,不管是内存管理,多流合并,还是时间窗口,迭代处理上,Flink在实时计算场景更较适合.而Flink的St ...
- Flink从入门到精通100篇(三)-如何利用InfluxDB+Grafana搭建Flink on YARN作业监控大屏环境
前言 虽然博主之前写过基于Prometheus PushGateway搭建Flink监控的过程,但是在我们的生产环境中,使用的是InfluxDB.InfluxDB是一个由Go语言写成的.由Influx ...
- Flink从入门到精通100篇(十三)-Flink的入门教学
前言 Flink 是一种流式计算框架,为什么我会接触到 Flink 呢?因为我目前在负责的是监控平台的告警部分,负责采集到的监控数据会直接往 kafka 里塞,然后告警这边需要从 kafka topi ...
- Flink从入门到精通100篇(二十三)-Flink实战应用案例:如何清理过期的 Checkpoint 目录?
目录 Flink Checkpoint 目录的清除策略 生产环境应该选择哪种清除策略 生产环境必须定期脚本清理 Checkpoint 和 Savepoint 目录 RocksDB 增量 Checkpo ...
- Flink从入门到精通100篇(二十二)- Flink应用实战案例:如何实现网络流控与反压机制
目录 Flink 流处理为什么需要网络流控? Flink V1.5 版之前网络流控介绍 Flink V1.5 版之前的反压策略存在的问题 Credit的反压策略实现原理,Credit是如何解决 Fli ...
最新文章
- 为什么颜值越来越重要_看脸时代来了吗?为什么这个时代越来越注重颜值?
- win10终端仿真程序_win10下子系统的使用
- sharepoint 2010 如何使用sharepoint多媒体视频播放media webpart功能
- TCP滑动窗口(Sliding Window)原理
- UA MATH567 高维统计 专题1 Supervised PCA Regression概述
- Python必备知识点:对Json的基本使用方法
- Springboot利用poi导出excel下载
- 求职招聘市场复苏!市场平均薪资超8000元
- Linux中的sed命令,使用方法之一「替换字符串中的内容 」,以及「s/ / / 」和「s/ / /g」之间的区别
- 强化学习 —— gym
- POJ2456-Aggressive cows
- linux命令执行绕过,命令执行绕过
- 基于Java实现的免疫算法-克隆选择算法
- 计算机基础知识题二,计算机基础知识题库(五)
- 人工智能核心能力包括哪些层面?
- Android不透明度16进制值
- C++面向对象课程设计报告_快递系统
- JPA Native Query(本地查询)及查询结果转换
- 搭建文字转语音(TTS)服务器
- 《HelloGitHub》第 79 期
热门文章
- 网页插件学javascript还是jquery好啊?
- 邮件办公系统Exchange
- AcWing 845. 八数码(3阶数字华容道):bfs求最短路,状态表示困难
- 军用软件概算计价规范_超强干货分享:547建筑工程计量与计价,帮你轻松掌握计量与计价...
- python import gc_Python 2.6 GC似乎可以清理对象,但不会释放内存
- java console 交互_实例讲解java中Console类的用法
- python判断实例的类型
- linux 系统时间是在哪里记录的,Linux系统如何记录时间
- 双任务延时原理与空闲任务
- 音频在计算机中的存储