From c0895e56470acb30c8041319f7c059958b2dcf26 Mon Sep 17 00:00:00 2001
From: furq-aws <furq@amazon.com>
Date: Wed, 22 Mar 2023 18:56:26 -0700
Subject: [PATCH] Add wait for flaky
 restartAfterRequestTimerExpiresWhenInitialTaskExecutionIsRejected test

---
 .../amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java
index 7d0f9633..b628abe6 100644
--- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java
+++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java
@@ -400,6 +400,7 @@ public class ShardConsumerSubscriberTest {
         // First try to start subscriptions.
         synchronized (processedNotifier) {
             subscriber.startSubscriptions();
+            processedNotifier.wait(100);
         }
 
         // Verifying that there are no interactions with shardConsumer mock indicating no records were sent back and