commit 56a17f4b75e881359b848ea28c504fd8b36adfd5
author abhishekd0907 <43843989+abhishekd0907@users.noreply.github.com> Tue Oct 20 01:28:00 2020 +0530
committer GitHub <noreply@github.com> Mon Oct 19 12:58:00 2020 -0700
tree 5dc99926891c0cdbf4da9847a4f91a3acc9f4d37
parent 33d1a63e262b00a622e708f1945e8a6f6950668c

Properly propagate exceptions in SQSClient (#99)

sql-streaming-sqs/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala

diff --git a/sql-streaming-sqs/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala b/sql-streaming-sqs/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala
index 04bfb09..1d9bb97 100644
--- a/sql-streaming-sqs/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala
+++ b/sql-streaming-sqs/src/main/scala/org/apache/spark/sql/streaming/sqs/SqsClient.scala
@@ -220,11 +220,12 @@
           .standard()
           .withClientConfiguration(new ClientConfiguration().withMaxConnections(maxConnections))
           .withCredentials(instanceProfileCredentialsProvider)
+          .withRegion(region)
           .build()
       }
     } catch {
       case e: Exception =>
-        throw new SparkException(s"Error occured while creating Amazon SQS Client ${e.getMessage}")
+        throw new SparkException(s"Error occured while creating Amazon SQS Client", e)
     }
   }