From 7196a41cd43978f4ef354afd2d2239352056f82f Mon Sep 17 00:00:00 2001
From: Avinash Chowdary <AvinashChowdary@users.noreply.github.com>
Date: Wed, 16 Jun 2021 13:26:36 -0700
Subject: [PATCH] Removed wildcard imports from PR#815 (#828)

Co-authored-by: Avinash Ravilla <ravillaa@amazon.com>
---
 .../coordinator/GracefulShutdownCoordinator.java      |  5 ++++-
 .../amazon/kinesis/coordinator/Scheduler.java         | 11 ++++++++++-
 2 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/GracefulShutdownCoordinator.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/GracefulShutdownCoordinator.java
index 29bd699e..260e25d6 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/GracefulShutdownCoordinator.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/GracefulShutdownCoordinator.java
@@ -14,10 +14,13 @@
  */
 package software.amazon.kinesis.coordinator;
 
-import java.util.concurrent.*;
 
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.concurrent.Callable;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.TimeUnit;
+
 class GracefulShutdownCoordinator {
 
     CompletableFuture<Boolean> startGracefulShutdown(Callable<Boolean> shutdownCallable) {
diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
index e9431c15..781afe10 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java
@@ -31,7 +31,16 @@ import java.util.List;
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
-import java.util.concurrent.*;
+import java.util.concurrent.Callable;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.concurrent.ThreadLocalRandom;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 import java.util.function.Consumer;
 import java.util.function.Function;