atlas-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nixon Rodrigues (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (ATLAS-803) NotificationHookConsumerKafkaTest fails sometimes while running mvn clean install
Date Wed, 18 May 2016 07:16:12 GMT

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

Nixon Rodrigues updated ATLAS-803:
----------------------------------
    Description: 
Sometimes, while running mvn clean install exception comes: 
{noformat}
NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled and
NotificationHookConsumerKafkaTest.testConsumerRemainsAtSameMessageWithAutoCommitEnabled tests
fail, The exception seen is 
kafka.consumer.ConsumerTimeoutException: null
        at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:69)
        at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
        at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
        at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
        at org.apache.atlas.kafka.KafkaConsumer.hasNext(KafkaConsumer.java:69)
        at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.consumeOneMessage(NotificationHookConsumerKafkaTest.java:114)
        at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled(NotificationHookConsumerKafkaTest.java:68)
{noformat}

After adding Thread.sleep(10000) in the NotificationHookConsumerKafkaTest.setup method after
starting Kafka server, it passes.

  was:
Sometimes, while running mvn clean install exception comes: 
{noformat}
NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled and
NotificationHookConsumerKafkaTest.testConsumerRemainsAtSameMessageWithAutoCommitEnabled tests
fail, The exception seen is 
kafka.consumer.ConsumerTimeoutException: null
        at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:69)
        at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
        at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
        at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
        at org.apache.atlas.kafka.KafkaConsumer.hasNext(KafkaConsumer.java:69)
        at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.consumeOneMessage(NotificationHookConsumerKafkaTest.java:114)
        at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled(NotificationHookConsumerKafkaTest.java:68)
{noformat}


> NotificationHookConsumerKafkaTest fails sometimes while running mvn clean install
> ---------------------------------------------------------------------------------
>
>                 Key: ATLAS-803
>                 URL: https://issues.apache.org/jira/browse/ATLAS-803
>             Project: Atlas
>          Issue Type: Bug
>            Reporter: Nixon Rodrigues
>            Assignee: Hemanth Yamijala
>
> Sometimes, while running mvn clean install exception comes: 
> {noformat}
> NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled
and NotificationHookConsumerKafkaTest.testConsumerRemainsAtSameMessageWithAutoCommitEnabled
tests fail, The exception seen is 
> kafka.consumer.ConsumerTimeoutException: null
>         at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:69)
>         at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
>         at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
>         at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
>         at org.apache.atlas.kafka.KafkaConsumer.hasNext(KafkaConsumer.java:69)
>         at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.consumeOneMessage(NotificationHookConsumerKafkaTest.java:114)
>         at org.apache.atlas.notification.NotificationHookConsumerKafkaTest.testConsumerConsumesNewMessageWithAutoCommitDisabled(NotificationHookConsumerKafkaTest.java:68)
> {noformat}
> After adding Thread.sleep(10000) in the NotificationHookConsumerKafkaTest.setup method
after starting Kafka server, it passes.



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

Mime
View raw message