Salesforce bulk query does not retry upon timeout

Description

Caused by: java.lang.RuntimeException: Failed to run a Salesforce bulk query (select XYZ): ClientInputError : Failed to create batch
	at io.cdap.plugin.salesforce.plugin.source.batch.util.SalesforceSplitUtil.getBatches(SalesforceSplitUtil.java:88)
	at io.cdap.plugin.salesforce.plugin.source.batch.util.SalesforceSplitUtil.getQuerySplits(SalesforceSplitUtil.java:61)
	at io.cdap.plugin.salesforce.plugin.source.batch.SalesforceBatchSource.prepareRun(SalesforceBatchSource.java:133)
	at io.cdap.plugin.salesforce.plugin.source.batch.SalesforceBatchSource.prepareRun(SalesforceBatchSource.java:57)
	at io.cdap.cdap.etl.common.plugin.WrappedBatchSource.lambda$prepareRun$0(WrappedBatchSource.java:53)
	at io.cdap.cdap.etl.common.plugin.Caller$1.call(Caller.java:30)
	at io.cdap.cdap.etl.common.plugin.StageLoggingCaller.call(StageLoggingCaller.java:40)
	at io.cdap.cdap.etl.common.plugin.WrappedBatchSource.prepareRun(WrappedBatchSource.java:52)
	at io.cdap.cdap.etl.common.plugin.WrappedBatchSource.prepareRun(WrappedBatchSource.java:35)
	at io.cdap.cdap.etl.common.submit.SubmitterPlugin.lambda$prepareRun$2(SubmitterPlugin.java:74)
	at io.cdap.cdap.internal.app.runtime.AbstractContext.lambda$execute$5(AbstractContext.java:558)
	at io.cdap.cdap.data2.transaction.Transactions$CacheBasedTransactional.finishExecute(Transactions.java:234)
	... 21 common frames omitted
Caused by: com.sforce.async.AsyncApiException: ClientInputError : Failed to create batch
	at com.sforce.async.BulkConnection.createBatchFromStreamImpl(BulkConnection.java:247)
	at com.sforce.async.BulkConnection.createBatchFromStream(BulkConnection.java:217)
	at io.cdap.plugin.salesforce.plugin.source.batch.util.SalesforceSplitUtil.runBulkQuery(SalesforceSplitUtil.java:114)
	at io.cdap.plugin.salesforce.plugin.source.batch.util.SalesforceSplitUtil.getBatches(SalesforceSplitUtil.java:83)
	... 32 common frames omitted
Caused by: java.net.SocketTimeoutException: connect timed out
	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.net.Socket.connect(Socket.java:609)
	at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)
	at sun.net.NetworkClient.doConnect(NetworkClient.java:177)
	at sun.net.www.http.HttpClient.openServer(HttpClient.java:509)
	at sun.net.www.http.HttpClient.openServer(HttpClient.java:604)
	at sun.net.www.protocol.https.HttpsClient.<init>(HttpsClient.java:266)
	at sun.net.www.protocol.https.HttpsClient.New(HttpsClient.java:373)
	at sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.getNewHttpClient(AbstractDelegateHttpsURLConnection.java:207)
	at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1232)
	at sun.net.www.protocol.http.HttpURLConnection$6.run(HttpURLConnection.java:1071)
	at sun.net.www.protocol.http.HttpURLConnection$6.run(HttpURLConnection.java:1069)
	at java.security.AccessController.doPrivileged(Native Method)
	at java.security.AccessController.doPrivilegedWithCombiner(AccessController.java:795)
	at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1068)
	at sun.net.www.protocol.https.AbstractDelegateHttpsURLConnection.connect(AbstractDelegateHttpsURLConnection.java:193)
	at sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1367)
	at sun.net.www.protocol.http.HttpURLConnection$8.run(HttpURLConnection.java:1334)
	at sun.net.www.protocol.http.HttpURLConnection$8.run(HttpURLConnection.java:1332)
	at java.security.AccessController.doPrivileged(Native Method)
	at java.security.AccessController.doPrivilegedWithCombiner(AccessController.java:795)
	at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1331)
	at sun.net.www.protocol.https.HttpsURLConnectionImpl.getOutputStream(HttpsURLConnectionImpl.java:246)
	at com.sforce.ws.transport.JdkHttpTransport.connectRaw(JdkHttpTransport.java:143)
	at com.sforce.ws.transport.JdkHttpTransport.connectLocal(JdkHttpTransport.java:103)
	at com.sforce.ws.transport.JdkHttpTransport.connect(JdkHttpTransport.java:79)
	at com.sforce.async.BulkConnection.createBatchFromStreamImpl(BulkConnection.java:234)
	... 35 common frames omitted

Release Notes

None

Activity

Show:

Vikas - January 2, 2024 at 7:14 AM

Added with 1.6.2

Unresolved

Pinned fields

Click on the next to a field label to start pinning.

Details

Assignee

Saurabh Shrivastava

Reporter

Masoud Saeida Ardekani

Priority

Major

More fields

Created October 26, 2023 at 7:56 PM

Updated January 2, 2024 at 7:14 AM

Configure