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

ASF GitHub Bot commented on KAFKA-6765:
---------------------------------------

rajinisivaram opened a new pull request #4869: KAFKA-6765: Handle exception 
while reading throttle metric value in test
URL: https://github.com/apache/kafka/pull/4869
 
 
   CustomQuotaCallback tests wait for throttle metric to be updated without 
waiting for requests to complete to avoid waiting for potentially large 
throttle times. This requires the test to read metric values while a broker may 
be updating the value, resulting in exception in the test. Add retry in the 
test to handle this case.
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


> Intermittent test failure in CustomQuotaCallbackTest
> ----------------------------------------------------
>
>                 Key: KAFKA-6765
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6765
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 1.2.0
>            Reporter: Rajini Sivaram
>            Assignee: Rajini Sivaram
>            Priority: Major
>             Fix For: 1.2.0
>
>
> Exception stack trace:
> {quote}
> java.lang.NullPointerException at 
> org.apache.kafka.common.metrics.stats.SampledStat.purgeObsoleteSamples(SampledStat.java:104)
>  at 
> org.apache.kafka.common.metrics.stats.SampledStat.measure(SampledStat.java:74)
>  at 
> org.apache.kafka.common.metrics.KafkaMetric.metricValue(KafkaMetric.java:68) 
> at kafka.api.QuotaTestClients$.metricValue(BaseQuotaTest.scala:163) at 
> kafka.api.QuotaTestClients.produceUntilThrottled(BaseQuotaTest.scala:193) at 
> kafka.api.CustomQuotaCallbackTest$GroupedUser.produceConsume(CustomQuotaCallbackTest.scala:272)
>  at 
> kafka.api.CustomQuotaCallbackTest.testCustomQuotaCallback(CustomQuotaCallbackTest.scala:146)
> {quote}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to