You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Ashish Paliwal (JIRA)" <ji...@apache.org> on 2014/11/05 12:34:34 UTC
[jira] [Resolved] (FLUME-1667) Errors in source RegexExtractor
[ https://issues.apache.org/jira/browse/FLUME-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ashish Paliwal resolved FLUME-1667.
-----------------------------------
Resolution: Won't Fix
Fix Version/s: v0.9.5
Won't fix. 0.X branch not maintained anymore
> Errors in source RegexExtractor
> -------------------------------
>
> Key: FLUME-1667
> URL: https://issues.apache.org/jira/browse/FLUME-1667
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v0.9.4
> Reporter: Sergey
> Fix For: v0.9.5
>
>
> We are experiencing some problems with Flume that randomly happen on our systems 2 or more times per day. Here is what they look like...
> This is the first sensible message in logs regarding this issue:
> ...
> 2012-10-23 15:02:27,021 INFO com.cloudera.flume.handlers.debug.StubbornAppendSink: append failed on event 'xservice-backend02 [INFO Tue Oct 23 15:02:12
> UTC 2012] { AckChecksum : (long)1613444596 (string) '....`+5�' (double)7.971475464E-315 } { AckTag : 20121023-150211682+0000.2380890497695726.00000068 } {
> AckType : msg } { ds : 2012-10-23 } { tailSrcFile : operation.xservice-backend02.log } 2012-10-23 15:02:12,053 \tRESP\txaxpxo\tf0bdc8efc9df943380359bc4
> f5a1058e76\t/0/poster/\tPOST\t\"force_rewrite\": \"1\", \"session_key\": \"f0bdc8efc9df943380359bc4f5a1058e76\", \"filesize\": \"73\", \"name\": \"/Download/
> aspect/TRANSITIVE AND ARGUMENT STRUCTURE.pdf\"\t6c86d15a5593c90381ef2d0b33fa7aa9\t0.0876088142395\t3\tpc:0.992:en:lan:Virtual Drive:\tCloud_Syncer\t' w
> ith error: Blocked append interrupted by rotation event
> After a few seconds exceptions appear:
> ...
> 2012-10-23 15:02:31,769 INFO com.cloudera.flume.handlers.debug.InsistentAppendDecorator: Failed due to unexpected runtime exception during append attempt
> java.lang.RuntimeException: Blocked append interrupted by rotation event
> at com.cloudera.flume.handlers.rolling.RollSink.append(RollSink.java:215)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.core.MaskDecorator.append(MaskDecorator.java:43)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.debug.InsistentOpenDecorator.append(InsistentOpenDecorator.java:169)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.debug.StubbornAppendSink.append(StubbornAppendSink.java:71)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.debug.InsistentAppendDecorator.append(InsistentAppendDecorator.java:110)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.endtoend.AckChecksumChecker.append(AckChecksumChecker.java:172)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.batch.UnbatchingDecorator.append(UnbatchingDecorator.java:62)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.batch.GunzipDecorator.append(GunzipDecorator.java:81)
> at com.cloudera.flume.collector.CollectorSink.append(CollectorSink.java:241)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.core.extractors.RegexExtractor.append(RegexExtractor.java:88)
> at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:133)
> 2012-10-23 15:02:31,770 WARN com.cloudera.flume.core.connector.DirectDriver: Exception in sink: RegexExtractor
> java.lang.RuntimeException: Blocked append interrupted by rotation event
> at com.cloudera.flume.handlers.rolling.RollSink.append(RollSink.java:215)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.core.MaskDecorator.append(MaskDecorator.java:43)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.debug.InsistentOpenDecorator.append(InsistentOpenDecorator.java:169)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.debug.StubbornAppendSink.append(StubbornAppendSink.java:71)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.debug.InsistentAppendDecorator.append(InsistentAppendDecorator.java:110)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.endtoend.AckChecksumChecker.append(AckChecksumChecker.java:172)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.batch.UnbatchingDecorator.append(UnbatchingDecorator.java:62)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.handlers.batch.GunzipDecorator.append(GunzipDecorator.java:81)
> at com.cloudera.flume.collector.CollectorSink.append(CollectorSink.java:241)
> at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
> at com.cloudera.flume.core.extractors.RegexExtractor.append(RegexExtractor.java:88)
> at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:133)
> 2012-10-23 15:02:31,770 WARN com.cloudera.flume.core.connector.DirectDriver: Retrying after Error in source: RegexExtractor
> 2012-10-23 15:02:31,770 INFO com.cloudera.flume.handlers.rolling.RollSink: closing RollSink 'escapedCustomDfs("hdfs://cdh-master.domain.com:54310/user/flume/x_backends/ds=%{ds}","x_backends.log%{rolltag}" )'
> 2012-10-23 15:02:31,770 INFO com.cloudera.flume.handlers.rolling.RollSink: double close 'escapedCustomDfs("hdfs://cdh-master.domain.com:54310/user/flume/x_backends/ds=%{ds}","x_backends.log%{rolltag}" )'
> 2012-10-23 15:02:31,771 WARN com.cloudera.flume.handlers.endtoend.AckChecksumChecker: partial acks abandoned: {20121023-150211682+0000.2380890497695726.00000068=1350995824815}
> 2012-10-23 15:02:31,771 INFO com.cloudera.flume.handlers.rolling.RollSink: opening RollSink 'escapedCustomDfs("hdfs://cdh-master.domain.com:54310/user/flume/x_backends/ds=%{ds}","x_backends.log%{rolltag}" )'
> 2012-10-23 15:02:31,772 INFO com.cloudera.flume.handlers.debug.InsistentOpenDecorator: Opened MaskDecorator on try 0
> 2012-10-23 15:02:31,772 INFO com.cloudera.flume.core.connector.DirectDriver: Sink Retry successful
> 2012-10-23 15:02:31,772 ERROR com.cloudera.flume.core.connector.DirectDriver: Closing down due to exception during append calls
> 2012-10-23 15:02:31,772 INFO com.cloudera.flume.core.connector.DirectDriver: Connector logicalNode flume_master_x_backends.log-20 exited with error: Event already had an event with attribute ds
> java.lang.IllegalArgumentException: Event already had an event with attribute ds
> at com.cloudera.flume.core.EventBaseImpl.set(EventBaseImpl.java:62)
> at com.cloudera.flume.core.Attributes.setString(Attributes.java:112)
> at com.cloudera.flume.core.extractors.RegexExtractor.append(RegexExtractor.java:87)
> at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:150)
> 2012-10-23 15:02:31,772 INFO com.cloudera.flume.collector.CollectorSource: closed
> 2012-10-23 15:02:32,773 INFO com.cloudera.flume.handlers.thrift.ThriftEventSource: Closed server on port 35854...
> 2012-10-23 15:02:32,773 INFO com.cloudera.flume.handlers.thrift.ThriftEventSource: Queue still has 182 elements ...
> ...
> And no service listening on port 35854 anymore.
> Our Flume configuration:
> exec map flume-master.domain.com flume_master_x_backends.log
> exec map xservice-backend02 backend02_x_backends.log
> exec config backend02_x_backends.log x_backends.log 'tail("/mnt/log/operation.xservice-backend02.log")' 'agentSink("flume-master.domain.com", 35854)'
> exec config flume_master_x_backends.log x_backends.log 'collectorSource(35854)' '{ regex("^2[0-9]{3}-[0-9]{2}-[0-9]{2}",0,"ds") => collectorSink("hdfs://cdh-master.domain.com:54310/user/flume/x_backends/ds=%{ds}", "x_backends.log") }'
> The strange part is that everything worked fine for months using this particular configuration. Could you please provide some comments as this looks like a bug. We are using Flume 0.9.4-cdh3u5
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)