[ xcly原创于iteye,见http://xcly.iteye.com ]
今天介绍Flume里面用到的BackoffAlgo算法,接口由BackoffPolicy定义,让我们看看下面的几个关键的方法
reset:Reset backoff state. Call this after successful attempts.每一次成功调用之后reset状态。
backoff:Modify state as if a backoff had just happened. Call this after failed attempts。失败发生时调用的回退犯法。
isFailed:Has so much time passed that we assume the failure is irrecoverable? 如果返回true,不再尝试。
sleepIncrement:Wait time in millis until RetryOk should be true
waitUntilRetryOk:Wait until it's ok to retry.
在InsistentAppendDecorator, InsistentOpenDecorator中调用了BackoffPolicy的子类CumulativeCappedExponentialBackoff,CumulativeCappedExponentialBackoff中的isfailed总是返回true,永远不会失败;总是不断尝试。
分享到:
相关推荐
flume 1.8所有源代码 编译通过版 附 maven3.5.2 安装包 解压配置maven,利用命令行进行编译,导入eclipse,可用于源代码查看,搭建flume远程测试环境
flume源码
电商数仓项目(八) Flume(2) 拦截器开发源代码
Flume读取数据库JDBC源程序,这样Flume就可以读取关系型数据作为数据源,通过简单配置即可实现数据库连接
flume1.6 es5.2.2
flume kafka storm集成源代码和文档介绍
Flume1.6.0入门:安装、部署、及flume的案例
Flume是Cloudera提供的一个高可用的,高可靠的,分布式的海量日志采集、聚合和传输的系统,Flume支持在日志系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可...
flume-ng安装
Log4j直接发送数据到Flume + Kafka (方式一) 通过flume收集系统日记, 收集的方式通常采用以下. 系统logs直接发送给flume系统, 本文主要记录种方式进行说明. 文章链接,请看:...
http://blog.csdn.net/m0_37739193/article/details/78779052这篇文章中所需的代码
01_Flume的介绍及其架构组成 02_Flume的安装部署 03_Flume的测试运行 04_Flume中配置使用file channel及HDFS sink 05_Flume中配置HDFS文件生成大小及时间分区 06_Flume中配置Spooling Dir的使用 07_Flume中...
尚硅谷大数据技术之Flume
Flume-ng在windows环境搭建并测试+log4j日志通过Flume输出到HDFS 11111
flume集群环境搭建,详细讲解,图文并茂,包括flume信息监控和众多文章链接
flume支持RabbitMQ插件
由于Flume的netcatudp为sources,avro为sink时,udp数据发送会报null of map in field headers of org.apache.flume.source.avro.AvroFlumeEvent of array。但是此类解决了这个问题。只需要将此类放在Flume安装的lib...
flume log4f示例源码
flume官网下载太慢,请从这里下载,次文件是官方网站的1.8版本,也就是支持jdk1.8的,不支持jdk1.7,如果要支持jdk1.7的,请下载我的资源里面也有,flume1.7,