flume-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLUME-2936) KafkaSource tests arbitrarily fail
Date Sat, 09 Jul 2016 22:11:11 GMT

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

ASF subversion and git services commented on FLUME-2936:

Commit 209c1e2548080525919fe78a1a61cc8fc7ab306f in flume's branch refs/heads/trunk from [~mpercy]
[ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=209c1e2 ]

FLUME-2936. KafkaSource tests: Use loopback instead of host address

TestKafkaSource is flaky because it tries to run Kafka on the host
address instead of the loopback address. This patch fixes that problem.

It also introduces a bug fix related to passing properties to

(Lior Zeno via Mike Percy)

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

View raw message