diff --git a/services/kinesis/src/it/java/software/amazon/awssdk/services/kinesis/KinesisIntegrationTests.java b/services/kinesis/src/it/java/software/amazon/awssdk/services/kinesis/KinesisIntegrationTests.java index 3237cd52b132..6f9d4bf4ac2a 100644 --- a/services/kinesis/src/it/java/software/amazon/awssdk/services/kinesis/KinesisIntegrationTests.java +++ b/services/kinesis/src/it/java/software/amazon/awssdk/services/kinesis/KinesisIntegrationTests.java @@ -116,6 +116,7 @@ public void testCreatePutGetDelete() throws Exception { // Wait for it to become ACTIVE. List shards = waitForStream(streamName); + Thread.sleep(1000); Assert.assertEquals(1, shards.size()); Shard shard = shards.get(0);