[KAFKA-4186] Transient failure in KStreamAggregationIntegrationTest

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Cannot Reproduce
• Component/s: streams
• Assignee: Matthias J. Sax
• Reporter: Jason Gustafson
• Created: 16/Sep/16 22:23
• Updated: 01/Mar/19 22:41
• Resolved: 01/Mar/19 22:41

Description

Saw this running locally off of trunk:

org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest > shouldGroupByKey[1] FAILED
    java.lang.AssertionError: Condition not met within timeout 60000. Did not receive 10 number of records
        at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:268)
        at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:211)
        at org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest.receiveMessages(KStreamAggregationIntegrationTest.java:480)
        at org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest.shouldGroupByKey(KStreamAggregationIntegrationTest.java:407)

----------------

Re-opening this issue with a different test, but it seems the test suite itself has a timing-dependent flakiness.

Stacktrace
java.lang.AssertionError: Condition not met within timeout 30000. metadata for topic=output-9 partition=0 not propagated to all brokers
	at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276)
	at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMetadataIsPropagated(IntegrationTestUtils.java:254)
	at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitForTopicPartitions(IntegrationTestUtils.java:246)
	at org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.createTopic(EmbeddedKafkaCluster.java:209)
	at org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.createTopics(EmbeddedKafkaCluster.java:168)
	at org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest.createTopics(KStreamAggregationIntegrationTest.java:680)
	at org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest.before(KStreamAggregationIntegrationTest.java:105)
...

Example: https://builds.apache.org/job/kafka-pr-jdk7-scala2.11/10564/testReport/junit/org.apache.kafka.streams.integration/KStreamAggregationIntegrationTest/shouldAggregateWindowed/