Skip to content

KAFKA-8748: Fix flaky testDescribeLogDirsRequest#7182

Merged
ijuma merged 1 commit intoapache:trunkfrom
ijuma:kafka-8748-fix-flaky-test-describe-log-dirs-request
Aug 9, 2019
Merged

KAFKA-8748: Fix flaky testDescribeLogDirsRequest#7182
ijuma merged 1 commit intoapache:trunkfrom
ijuma:kafka-8748-fix-flaky-test-describe-log-dirs-request

Conversation

@ijuma
Copy link
Copy Markdown
Member

@ijuma ijuma commented Aug 9, 2019

The introduction of KIP-480: Sticky Producer Partitioner had the
side effect that generateAndProduceMessages can often write
messages to a lower number of partitions to improve batching.

testDescribeLogDirsRequest (and potentially other tests) relies
on the messages being written somewhat uniformly to the topic
partitions. We fix the issue by including a monotonically
increasing key in the produced messages.

I also included a couple of minor clean-ups I noticed while
debugging the issue.

The test failed very frequently when executed locally before the
change and it passed 100 times consecutively after the change.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

…equest

The introduction of KIP-480: Sticky Producer Partitioner had the
side effect that `generateAndProduceMessages` can often write
messages to a lower number of partitions to improve batching.

`testDescribeLogDirsRequest` (and potentially other tests) relies
on the messages being written somewhat uniformly to the topic
partitions. We fix the issue by including a monotonically
increasing key in the produced messages.
@ijuma ijuma requested a review from rajinisivaram August 9, 2019 05:17
@ijuma ijuma changed the title KAFKA-8748: Fix flaky DescribeLogDirsRequestTest#testDescribeLogDirsRequest KAFKA-8748: Fix flaky testDescribeLogDirsRequest Aug 9, 2019
@ijuma
Copy link
Copy Markdown
Member Author

ijuma commented Aug 9, 2019

cc @jolshan @cmccabe

@ijuma ijuma requested a review from omkreddy August 9, 2019 05:20
Copy link
Copy Markdown
Contributor

@omkreddy omkreddy left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@ijuma Thanks for the PR. LGTM.

@ijuma
Copy link
Copy Markdown
Member Author

ijuma commented Aug 9, 2019

Two builds passed and one failed with the known flake org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest.testReconfigConnector. Merging to master.

@ijuma ijuma merged commit 600cc48 into apache:trunk Aug 9, 2019
@ijuma ijuma deleted the kafka-8748-fix-flaky-test-describe-log-dirs-request branch August 9, 2019 13:16
ijuma added a commit to confluentinc/kafka that referenced this pull request Aug 9, 2019
* apache-github/trunk:
  MINOR: Ignore dynamic log4j log level tests (apache#7183)
  KAFKA-8748: Fix flaky testDescribeLogDirsRequest (apache#7182)
  KAFKA-8598: Use automatic RPC generation in RenewDelegationToken
  KAFKA-8179: Part 3, Add PartitionsLost API for resetGenerations and metadata/subscription change (apache#6884)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants