spark git commit: [TEST][STREAMING] Fix flaky Kafka rate controlling test

2016-07-26 Thread tdas
Repository: spark Updated Branches: refs/heads/branch-2.0 4391d4a3c -> 44234b1c4 [TEST][STREAMING] Fix flaky Kafka rate controlling test ## What changes were proposed in this pull request? The current test is incorrect, because - The expected number of messages does not take into account

spark git commit: [TEST][STREAMING] Fix flaky Kafka rate controlling test

2016-07-26 Thread tdas
Repository: spark Updated Branches: refs/heads/master 6959061f0 -> 03c27435a [TEST][STREAMING] Fix flaky Kafka rate controlling test ## What changes were proposed in this pull request? The current test is incorrect, because - The expected number of messages does not take into account that