[jira] [Updated] (FLUME-2936) KafkaSource tests arbitrarily fail

["Lior Zeno (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLUME-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Lior Zeno updated FLUME-2936:
-----------------------------
    Attachment: FLUME-2936-0.patch

> KafkaSource tests arbitrarily fail 
> -----------------------------------
>
>                 Key: FLUME-2936
>                 URL: https://issues.apache.org/jira/browse/FLUME-2936
>             Project: Flume
>          Issue Type: Bug
>          Components: Test
>    Affects Versions: v1.7.0
>            Reporter: Lior Zeno
>             Fix For: v1.7.0
>
>         Attachments: FLUME-2936-0.patch
>
>
> KafkaSource tests are flaky, and tend to fail. I investigated this issue and discovered the following issues:
> * KafkaSource hangs in doStart at line 413:
> {code:title=KafkaSourceEmbeddedKafka.java|borderStyle=solid}
>  it = consumer.poll(1000).iterator();
> {code}
> I fixed that by simply changing HOST in KafkaSourceEmbeddedKafka to localhost.
> * Out of memory exception. I fixed that by properly configuring MAVEN_OPTS, as stated in the documentation.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)