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