You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Joydeep Sen Sarma (Commented) (JIRA)" <ji...@apache.org> on 2011/12/09 08:32:40 UTC
[jira] [Commented] (FLUME-875) tailsource gets interruptedexception
and exits - master reports everything healthy
[ https://issues.apache.org/jira/browse/FLUME-875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13165906#comment-13165906 ]
Joydeep Sen Sarma commented on FLUME-875:
-----------------------------------------
2011-12-09 01:37:24,840 ERROR com.cloudera.flume.core.connector.DirectDriver: Expected IDLE but timed out in state ACTIVE
2011-12-09 01:37:24,840 WARN com.cloudera.flume.handlers.text.TailSource: next unexpectedly interrupted :null
java.lang.InterruptedException
at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:877)
at com.cloudera.flume.handlers.text.TailSource.next(TailSource.java:263)
at com.cloudera.flume.handlers.text.TailDirSource.next(TailDirSource.java:270)
at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:105)
2011-12-09 01:37:24,840 ERROR com.cloudera.flume.core.connector.DirectDriver: Closing down due to exception during append calls
2011-12-09 01:37:24,840 INFO com.cloudera.flume.core.connector.DirectDriver: Connector logicalNode agent-flow-30 exited with error: null
2011-12-09 01:37:24,840 ERROR com.cloudera.util.dirwatcher.DirWatcher:
java.lang.InterruptedException
at java.lang.Object.wait(Native Method)
at java.lang.Thread.join(Thread.java:1186)
at java.lang.Thread.join(Thread.java:1239)
at com.cloudera.util.dirwatcher.DirWatcher.stop(DirWatcher.java:92)
at com.cloudera.flume.handlers.text.TailDirSource.close(TailDirSource.java:247)
at com.cloudera.flume.core.connector.DirectDriver$PumperThread.ensureClosed(DirectDriver.java:142)
at com.cloudera.flume.core.connector.DirectDriver$PumperThread.errorCleanup(DirectDriver.java:163)
at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:116)
2011-12-09 01:37:24,840 INFO com.cloudera.util.dirwatcher.DirWatcher: Stopped dir watcher thread
2011-12-09 01:37:24,840 INFO com.cloudera.flume.handlers.thrift.ThriftEventSink: ThriftEventSink on port 35853 closed
2011-12-09 01:37:24,840 ERROR com.cloudera.flume.core.connector.DirectDriver: Exiting driver logicalNode agent-flow-30 in error state TailDirSource | FileNameDecorator because null
2011-12-09 01:37:24,850 INFO com.cloudera.flume.handlers.text.TailSource: TailThread has exited
> tailsource gets interruptedexception and exits - master reports everything healthy
> ----------------------------------------------------------------------------------
>
> Key: FLUME-875
> URL: https://issues.apache.org/jira/browse/FLUME-875
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v0.9.4
> Environment: debian lenny, java 1.6.0
> Reporter: Joydeep Sen Sarma
>
> have a standard taildir source. the logs show it throws interrupted exception (problem #1 - not clear why) and quits. however master continues to report the agent as healthy (not sure that's a feature or a bug). detailed logs in first comment.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira