Eek, this was worse than I thought. Turns out message continued to be added to the channels, but no transactions could complete to take messages out of the channel. I've moved the file channels out of the way and restarted the service for now ... but how can I recover the rest of the data in these filechannels?
On May 10, 2013, at 10:29 AM, Matt Wise <[email protected]> wrote: > We were messing around with a few settings today and ended up getting a few > messages into our channel that are bad (corrupt time field). How can I clear > them out? > >> 10 May 2013 17:28:26,920 ERROR >> [SinkRunner-PollingRunner-DefaultSinkProcessor] >> (org.apache.flume.SinkRunner$PollingRunner.run:160) - Unable to deliver >> event. Exception follows. >> org.apache.flume.EventDeliveryException: java.lang.RuntimeException: Flume >> wasn't able to parse timestamp header in the event to resolve time based >> bucketing. Please check that you're correctly populating timestamp header >> (for example using TimestampInterceptor source interceptor). >> at >> org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:461) >> at >> org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) >> at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147) >> at java.lang.Thread.run(Thread.java:679) >> Caused by: java.lang.RuntimeException: Flume wasn't able to parse timestamp >> header in the event to resolve time based bucketing. Please check that >> you're correctly populating timestamp header (for example using >> TimestampInterceptor source interceptor). >> at >> org.apache.flume.formatter.output.BucketPath.replaceShorthand(BucketPath.java:160) >> at >> org.apache.flume.formatter.output.BucketPath.escapeString(BucketPath.java:343) >> at >> org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:392) >> ... 3 more >> Caused by: java.lang.NumberFormatException: null >> at java.lang.Long.parseLong(Long.java:401) >> at java.lang.Long.valueOf(Long.java:535) >> at >> org.apache.flume.formatter.output.BucketPath.replaceShorthand(BucketPath.java:158) >> ... 5 more > > This message just keeps repeating over and over again.. new events are coming > through just fine.
