Handling to include the full exception object

Author: psainics

src/main/java/io/cdap/plugin/salesforce/plugin/source/batch/util/BulkConnectionRetryWrapper.java

@@ -64,7 +64,7 @@ public JobInfo createJob(JobInfo jobInfo) throws AsyncApiException {
           try {
             return bulkConnection.createJob(jobInfo);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (JobInfo) resultJobInfo;
@@ -80,7 +80,7 @@ public JobInfo getJobStatus(String jobId) throws AsyncApiException {
           try {
             return bulkConnection.getJobStatus(jobId);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (JobInfo) resultJobInfo;
@@ -97,7 +97,7 @@ public void updateJob(JobInfo jobInfo) throws AsyncApiException {
           try {
             return bulkConnection.updateJob(jobInfo);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
   }
@@ -112,7 +112,7 @@ public BatchInfoList getBatchInfoList(String jobId) throws AsyncApiException {
           try {
             return bulkConnection.getBatchInfoList(jobId);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (BatchInfoList) batchInfoList;
@@ -128,7 +128,7 @@ public BatchInfo getBatchInfo(String jobId, String batchId) throws AsyncApiExcep
           try {
             return bulkConnection.getBatchInfo(jobId, batchId);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (BatchInfo) batchInfo;
@@ -144,7 +144,7 @@ public InputStream getBatchResultStream(String jobId, String batchId) throws Asy
           try {
             return bulkConnection.getBatchResultStream(jobId, batchId);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (InputStream) inputStream;
@@ -160,7 +160,7 @@ public InputStream getQueryResultStream(String jobId, String batchId, String res
           try {
             return bulkConnection.getQueryResultStream(jobId, batchId, resultId);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (InputStream) inputStream;
@@ -177,7 +177,7 @@ public BatchInfo createBatchFromStream(String query, JobInfo job) throws AsyncAp
           try {
             return createBatchFromStreamI(query, job);
           } catch (AsyncApiException e) {
-            throw new SalesforceQueryExecutionException(e.getMessage());
+            throw new SalesforceQueryExecutionException(e);
           }
         });
     return (BatchInfo) batchInfo;