第12课 :Spark Streaming源码解读之Executor容错安全性
2016-05-22 16:50
543 查看
第12课 :Spark Streaming源码解读之Executor容错安全性
/* 王家林老师授课http://weibo.com/ilovepains 每天晚上20:00YY频道现场授课频道68917580*/
1、从数据安全的角度考虑,Spark Streaming不断的接收数据,不断的生成job,不断的提交job,数据的安全性是至关重要问题。
2、Spark Streaming基于spark core,运行的过程中,借助spark core的rdd自动恢复。
因此首先保证数据的安全容错。数据层面的安全容错之上,计算、调度层面的安全容错主要是spark core实现的容错,天然就是安全容错的。
数据的2种安全容错方式,没有第三种方式了。
1、支持副本 借助blockmanager做备份 storgelever。disk and memory 2
2、支持重放--反复读取数据,例如过去10秒的数据。
tips:听spark streaming吃力唯一的问题是对spark core 掌握不够,内功不够。spark core 真的最重要的!!无为而无所不为!
StorageLevel
/* 王家林老师授课http://weibo.com/ilovepains 每天晚上20:00YY频道现场授课频道68917580*/
1、从数据安全的角度考虑,Spark Streaming不断的接收数据,不断的生成job,不断的提交job,数据的安全性是至关重要问题。
2、Spark Streaming基于spark core,运行的过程中,借助spark core的rdd自动恢复。
因此首先保证数据的安全容错。数据层面的安全容错之上,计算、调度层面的安全容错主要是spark core实现的容错,天然就是安全容错的。
数据的2种安全容错方式,没有第三种方式了。
1、支持副本 借助blockmanager做备份 storgelever。disk and memory 2
2、支持重放--反复读取数据,例如过去10秒的数据。
tips:听spark streaming吃力唯一的问题是对spark core 掌握不够,内功不够。spark core 真的最重要的!!无为而无所不为!
@DeveloperApi class StorageLevel private( private var _useDisk: Boolean, private var _useMemory: Boolean, private var _useOffHeap: Boolean, private var _deserialized: Boolean, private var _replication: Int = 1) extends Externalizable
StorageLevel
相关文章推荐
- Java中定义和声明的区别
- 【深入SpringBoot 1.3.5 第一章】Boot应用的启动流程
- 【转】ArcGIS中File Geodatabase与Personal Geodatabase的区别
- 一天一点MySQL复习——存储过程
- 一个纯小白的安装python库的郁闷之旅
- 状态栏
- 判断一个元素是否已经存在
- java返回1到54之间不包括某些数的随机数
- Sql Server系列:分区表操作
- Qunie问题
- iOS逆向工程读书笔记
- TensorFlow人工智能引擎入门教程所有目录
- Spring xml 配置使用外部config 文件
- 在Dos下初步使用MySQL
- 打造绚丽的ViewPager
- 0 1 背包问题
- 2016"百度之星" - 初赛(Astar Round2B)
- php数组----初探谈任何语言恒古不变的是算法和思想谈与Java中的数组对比
- EventBus3.0使用
- 在jQueryEasyui datagrid加载完成后清除选中