This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 80aea23 KAFKA-9295: increase startup timeout for flaky test in
KTableKTableForeignKeyInnerJoinMultiIntegrationTest (#10635)
80aea23 is described below
commit 80aea23beb2654b2a53e0248387f2b4dbc0f0dc1
Author: Luke Chen <[email protected]>
AuthorDate: Thu May 6 12:58:27 2021 +0800
KAFKA-9295: increase startup timeout for flaky test in
KTableKTableForeignKeyInnerJoinMultiIntegrationTest (#10635)
Try to address the extreme flakiness of
shouldInnerJoinMultiPartitionQueryable since the recent test cleanup. Since we
need to wait for 3 streams reach RUNNING state, it makes sense to increase the
waiting time to make the test more reliable.
Reviewers: Anna Sophie Blee-Goldman <[email protected]>
---
.../KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
index 6156c48..92520fb 100644
---
a/streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
+++
b/streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
@@ -194,7 +194,7 @@ public class
KTableKTableForeignKeyInnerJoinMultiIntegrationTest {
streamsThree = prepareTopology(queryableName, queryableNameTwo,
streamsConfigThree);
final List<KafkaStreams> kafkaStreamsList = asList(streams,
streamsTwo, streamsThree);
- startApplicationAndWaitUntilRunning(kafkaStreamsList, ofSeconds(60));
+ startApplicationAndWaitUntilRunning(kafkaStreamsList, ofSeconds(120));
final Set<KeyValue<Integer, String>> result = new
HashSet<>(IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(
CONSUMER_CONFIG,
