栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink运行架构及相关命令

Flink运行架构及相关命令

Flink运行架构及相关命令

最近学习了Flink,整理了一些关于flink函数框架运行和相关算子的运算方法。

flink阿里17年开始开源blink,里面融合的部分flink功能,比如flink SQL

Flink项目的理念是:“Apache Flink是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源的有状态的流处理框架”。

​ Apache Flink是一个框架分布式处理引擎,用于对无界和有界数据流进行有状态计算 。Flink被设计在所有常见的集群环境中运行,以内存执行速度任意规模来执行计算。

状态相当于历史数据。

flink可以相当于三部分来学习。

相关运行命令
指令功能
Flink提交任务参数
flink执行任务脚本
run执行作业(ApplicationMode模式除外)
run-applicationApplicationMode模式的执行作业
-d后台运行
-m指定JobManager
-c指定全类名
-D如果要指定其它配置,可以跟在-D 后面 格式:(-D参数名=参数值)
-t指定以yarn的什么模式,yarn-per-job yarn-session yarn-application
-p提交任务时指定并行度
运行架构

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/487561.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号