Заголовок флюма - добавить отметку времени

Question

У меня возникла проблема с добавлением метки времени в заголовок лотка. Здесь вырезано из моего файла conf.

agent.sources.avrosource.interceptors.addTimestamp.type = org.apache.flume.interceptor.TimestampInterceptor$Builder 

Когда я отлаживаю с помощью maven, я вижу, что метка времени не добавляется в заголовок. Вот отладочный вывод:

2013-12-05 10:56:34,963 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - com.btoddb.flume.sinks.cassandra.CassandraSink.process(CassandraSink.java:135)] event: [Event headers = {key=value}, body.length = 12 ] 

FYI, я также добавить метку времени, как это, но опять же это не работает.

agent.sources.avrosource.interceptors = addTime 
agent.sources.avrosource.interceptors.addTime.type = timestamp 

Любая помощь будет оказана. Спасибо

Answer 1

если у вас есть это использованиеLocalTimeStamp на раковине, он должен работать.

agent.sinks.sinkdest.hdfs.useLocalTimeStamp = true