From 1d7170613017b5c902a4b6dca6c8d4276703b45d Mon Sep 17 00:00:00 2001
From: Arash Tavakkol <arash.tavakkol@fortum.com>
Date: Sun, 28 Mar 2021 23:09:21 +0200
Subject: [PATCH] Fix max throughput issue

---
 .../scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala b/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala
index b8c899d..16d5c6e 100644
--- a/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala
+++ b/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala
@@ -82,7 +82,7 @@ class SqsClient(sourceOptions: SqsSourceOptions,
     sqsFetchMessagesThread,
     0,
     sqsFetchIntervalSeconds,
-    TimeUnit.SECONDS)
+    TimeUnit.MILLISECONDS)
 
   private def sqsFetchMessages(): Seq[(String, Long, String)] = {
     val messageList = try {