Salesforce Connector fails with INVALID_SESSION_ID Error for create job bulk api v2

SYMPTOM

Salesforce Connector fails with INVALID_SESSION_ID error for the operation 'create job bulk API v2':

[2022-04-18 18:01:48.586] WARN    org.mule.extension.salesforce.internal.connection.ForceWSCConnection [[MuleRuntime].uber.05: [oauth00324590].
salesforce-CreateBulkJob.BLOCKING @36019a]: event:9bed91a0-bf41-11ec-b37f-02d8ee3b93a9 Couldn't obtain a valid response code because an error has occurred. 
An exception will be thrown. Arguments: {response=[{"message":"Session expired or invalid","errorCode":"INVALID_SESSION_ID"}], statusCode=401}.
[2022-04-18 18:01:48.586] DEBUG   org.mule.extension.salesforce.internal.error.exception.service.handlers.IOExceptionHandler [[MuleRuntime].uber.05: 
[oauth00324590].salesforce-CreateBulkJob.BLOCKING @36019a]: event:9bed91a0-bf41-11ec-b37f-02d8ee3b93a9 Exception encountered: Invalid status code: 401, 
response body: [{"message":"Session expired or invalid","errorCode":"INVALID_SESSION_ID"}]
java.io.IOException: Invalid status code: 401, response body: [{"message":"Session expired or invalid","errorCode":"INVALID_SESSION_ID"}]
	at org.mule.extension.salesforce.internal.connection.ForceWSCConnection.send(ForceWSCConnection.java:500)
	at org.mule.extension.salesforce.internal.service.BulkServiceImpl.createBulkV2(BulkServiceImpl.java:423)
	at org.mule.extension.salesforce.internal.operation.bulk.v2.CreateJobBulkApiV2Operation.createJobBulkApiV2(CreateJobBulkApiV2Operation.java:78)
	at org.mule.extension.salesforce.internal.operation.bulk.v2.CreateJobBulkApiV2Operation$createJobBulkApiV2$MethodComponentExecutor_oauth00324590.execute(Unknown Source)
	at org.mule.runtime.module.extension.internal.runtime.execution.GeneratedMethodComponentExecutor.execute(GeneratedMethodComponentExecutor.java:94)
	at org.mule.runtime.module.extension.internal.runtime.execution.CompletableMethodOperationExecutor.doExecute(CompletableMethodOperationExecutor.java:26)
	at org.mule.runtime.module.extension.internal.runtime.execution.AbstractCompletableMethodOperationExecutor.execute(AbstractCompletableMethodOperationExecutor.java:61)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.executeCommand(DefaultExecutionMediator.java:233)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.lambda$executeWithInterceptors$6(DefaultExecutionMediator.java:215)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.lambda$executeWithRetry$2(DefaultExecutionMediator.java:193)
	at net.jodah.failsafe.Functions.lambda$promiseOfStage$8(Functions.java:193)
	at net.jodah.failsafe.internal.executor.RetryPolicyExecutor$1.call(RetryPolicyExecutor.java:101)
	at net.jodah.failsafe.internal.executor.RetryPolicyExecutor.lambda$supplyAsync$1(RetryPolicyExecutor.java:133)
	at net.jodah.failsafe.Functions.lambda$null$1(Functions.java:69)
	at org.mule.runtime.core.internal.util.rx.ConditionalExecutorServiceDecorator.synchronousSchedule(ConditionalExecutorServiceDecorator.java:181)
	at org.mule.runtime.core.internal.util.rx.ConditionalExecutorServiceDecorator.schedule(ConditionalExecutorServiceDecorator.java:167)
	at net.jodah.failsafe.Functions.lambda$makeAsync$2(Functions.java:79)
	at net.jodah.failsafe.AsyncExecution.executeAsync(AsyncExecution.java:174)
	at net.jodah.failsafe.FailsafeExecutor.callAsync(FailsafeExecutor.java:346)
	at net.jodah.failsafe.FailsafeExecutor.getStageAsync(FailsafeExecutor.java:178)
	at org.mule.runtime.core.internal.retry.policies.SimpleRetryPolicy.applyPolicy(SimpleRetryPolicy.java:90)
	at org.mule.runtime.core.api.retry.policy.RetryPolicyTemplate.applyPolicy(RetryPolicyTemplate.java:143)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.executeWithRetry(DefaultExecutionMediator.java:191)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.executeWithInterceptors(DefaultExecutionMediator.java:215)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.lambda$execute$1(DefaultExecutionMediator.java:136)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.lambda$new$0(DefaultExecutionMediator.java:73)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.withExecutionTemplate(DefaultExecutionMediator.java:312)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.execute(DefaultExecutionMediator.java:135)
	at org.mule.runtime.module.extension.internal.runtime.operation.ComponentMessageProcessor.executeOperation(ComponentMessageProcessor.java:570)
	at org.mule.runtime.module.extension.internal.runtime.operation.OAuthOperationMessageProcessor.access$001(OAuthOperationMessageProcessor.java:42)
	at org.mule.runtime.module.extension.internal.runtime.operation.OAuthOperationMessageProcessor$1.error(OAuthOperationMessageProcessor.java:84)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator$1.error(DefaultExecutionMediator.java:180)
	at org.mule.runtime.module.extension.internal.runtime.operation.DeferredExecutorCallback.callDelegateMethod(DeferredExecutorCallback.java:105)
	at org.mule.runtime.module.extension.internal.runtime.operation.DeferredExecutorCallback.close(DeferredExecutorCallback.java:97)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.execute(DefaultExecutionMediator.java:139)
	at org.mule.runtime.module.extension.internal.runtime.operation.ComponentMessageProcessor.executeOperation(ComponentMessageProcessor.java:570)
	at org.mule.runtime.module.extension.internal.runtime.operation.OAuthOperationMessageProcessor.access$001(OAuthOperationMessageProcessor.java:42)
	at org.mule.runtime.module.extension.internal.runtime.operation.OAuthOperationMessageProcessor$1.error(OAuthOperationMessageProcessor.java:84)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator$1.error(DefaultExecutionMediator.java:180)
	at org.mule.runtime.module.extension.internal.runtime.operation.DeferredExecutorCallback.callDelegateMethod(DeferredExecutorCallback.java:105)
	at org.mule.runtime.module.extension.internal.runtime.operation.DeferredExecutorCallback.close(DeferredExecutorCallback.java:97)
	at org.mule.runtime.module.extension.internal.runtime.operation.DefaultExecutionMediator.execute(DefaultExecutionMediator.java:139)
	at org.mule.runtime.module.extension.internal.runtime.operation.ComponentMessageProcessor.executeOperation(ComponentMessageProcessor.java:570)
	at org.mule.runtime.module.extension.internal.runtime.operation.OAuthOperationMessageProcessor.executeOperation(OAuthOperationMessageProcessor.java:66)
	at org.mule.runtime.module.extension.internal.runtime.operation.ComponentMessageProcessor.prepareAndExecuteOperation(ComponentMessageProcessor.java:795)
	at org.mule.runtime.module.extension.internal.runtime.operation.ComponentMessageProcessor.access$100(ComponentMessageProcessor.java:197)
	at org.mule.runtime.module.extension.internal.runtime.operation.ComponentMessageProcessor$4.lambda$innerEventDispatcher$6(ComponentMessageProcessor.java:654)
	at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:832)
	at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:846)
	at reactor.core.publisher.FluxSubscribeOnValue$ScheduledScalar.run(FluxSubscribeOnValue.java:178)
	at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:50)
	at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:27)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at org.mule.service.scheduler.internal.AbstractRunnableFutureDecorator.doRun(AbstractRunnableFutureDecorator.java:151)
	at org.mule.service.scheduler.internal.RunnableFutureDecorator.run(RunnableFutureDecorator.java:54)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

CAUSE

The Salesforce session has expired.

SOLUTION

If no reconnection strategy is configured, please add one in the Salesforce Connector Config.

With the "Basic Authentication" connection type, Salesforce Connector treats the 401 status code with the message "Session expired or invalid" as a connection error and invalidates the cached session Id.

With a reconnection strategy configured, the connector will automatically trigger the login request again to obtain a new session Id and retry the "create job bulk api v2" operation.

If a reconnection strategy is not configured, triggering the "Create Job Bulk API v2" operation manually will prompt the connector to initiate a new login request to obtain a fresh session ID, as the previous session ID has been invalidated.

If the issue persists despite configuring a reconnection strategy and you are using Salesforce Connector version 10.14.4 or earlier with the OAuth 2.0 connection type, note that a bug affecting OAuth 2.0 connections was present in these versions. This issue was fixed in version 10.14.5. Please upgrade to the latest version of the Salesforce Connector to apply the fix.