GitHub user ppoulosk opened a pull request:
https://github.com/apache/storm/pull/1245
DO NOT MERGE [STORM-1646] Fix intermittent failures in storm-kafka unit
tests
This PR is dependent on the pr 1131, for STORM-822.
https://github.com/apache/storm/pull/1131
We have run into a few issues running storm-kafka unit tests on lightly
resourced VMs, especially after moving to kafka-9.
This moves the exponential backoff manager to use simulated time in
testing. We had been seeing races when using Thread.sleep with low sleep
periods.
It also switches a config no longer used in kafka 9 to the recommended
config parameter, and bumps up the timeout.
49394 [main] WARN o.a.k.c.p.KafkaProducer - metadata.fetch.timeout.ms
config is deprecated and will be removed soon. Please use max.block.ms
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ppoulosk/storm STORM-1646
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1245.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1245
----
commit afc3bdebd70faac9da6af907c18665f47604a012
Author: Hugo Louro <[email protected]>
Date: 2015-12-14T18:16:42Z
STORM-822: Kafka Spout New Consumer API
commit 1a98839e59f90c3c3b2819d5850b02f69b3a31d5
Author: Paul Poulosky <[email protected]>
Date: 2016-03-22T14:43:29Z
Adjust timeout, change define, fix error print, move to simulated time
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
