You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Arvind Prabhakar (Commented) (JIRA)" <ji...@apache.org> on 2011/11/22 02:42:40 UTC

[jira] [Commented] (FLUME-843) jdbc channel is sending unsolicited events to sink

    [ https://issues.apache.org/jira/browse/FLUME-843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13154815#comment-13154815 ] 

Arvind Prabhakar commented on FLUME-843:
----------------------------------------

@Will - can you please provide a log output for this problem? That will help me understand the issue better.
                
> jdbc channel is sending unsolicited events to sink
> --------------------------------------------------
>
>                 Key: FLUME-843
>                 URL: https://issues.apache.org/jira/browse/FLUME-843
>             Project: Flume
>          Issue Type: Bug
>          Components: Channel
>    Affects Versions: NG alpha 1
>         Environment: flume-728 branch, commit object 0014756b8462ed2711d2e3af4ccabcabff4fdc70
> Using this props file:
> host1.channels = jdbcChannel
> host1.sources = netcatSource
> host1.sinks = loggerSink
> #
> host1.channels.jdbcChannel.type=jdbc
> #
> host1.sources.netcatSource.type=netcat
> host1.sources.netcatSource.channels=jdbcChannel
> host1.sources.netcatSource.bind=localhost
> host1.sources.netcatSource.port=41414
> #
> host1.sinks.loggerSink.type=logger
> host1.sinks.loggerSink.channel=jdbcChannel
>            Reporter: Will McQueen
>            Assignee: Arvind Prabhakar
>
> Steps:
> Run the flume node with the above props.
> //exp: no LoggerSink msgs should be displayed, because we haven't yet connected to the netcat source
> //act:  a continuous output of LoggerSink messages is displayed. The contents of each message is an integer that increments with each LogSink msg (if you inspect the contents of the event, you see this)
> This unexpected behavior does not happen when the memory channel is used.

--
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