writing to salesforce destination consistently throws exception FORCE_13 - Error writing to Salesforce: , InvalidSessionId : Invalid session id

asked 2018-11-27 06:32:06 -0600

Anshul gravatar image

version : StreamSets Data Collector 3.1.3.0

Our pipeline flow reads data data from csv file (Datalake) , De-duplicate and then writes data to salesforce .

Reading data from CSV , Batch Size : 1000 records Threads : 1

But Pipeline flow frequently throws following exception while writing to salesforce : FORCE_13 - Error writing to Salesforce: , InvalidSessionId : Invalid session id

######################### Logs

2018-11-27 23:17:41,060 XXXXXX_to_salesforce_demo/XXXXXX INFO Created Bulk API job 7504F000001JgwxQAC ForceBulkWriter *admin 0 Spool Directory Runner - 0 2018-11-27 23:17:42,752 XXXXXX_to_salesforce_demo/XXXXXX INFO Wrote Bulk API batch: [BatchInfo id='7514F000001fezPQAQ' ForceBulkWriter *admin 0 Spool Directory Runner - 0 jobId='7504F000001JgwxQAC' state='Queued' stateMessage='null' createdDate='java.util.GregorianCalendar[time=1543321062000,areFieldsSet=true,areAllFieldsSet=true,lenient=true,zone=sun.util.calendar.ZoneInfo[id="GMT",offset=0,dstSavings=0,useDaylight=false,transitions=0,lastRule=null],firstDayOfWeek=1,minimalDaysInFirstWeek=1,ERA=1,YEAR=2018,MONTH=10,WEEK_OF_YEAR=48,WEEK_OF_MONTH=5,DAY_OF_MONTH=27,DAY_OF_YEAR=331,DAY_OF_WEEK=3,DAY_OF_WEEK_IN_MONTH=4,AM_PM=1,HOUR=0,HOUR_OF_DAY=12,MINUTE=17,SECOND=42,MILLISECOND=0,ZONE_OFFSET=0,DST_OFFSET=0]' systemModstamp='java.util.GregorianCalendar[time=1543321062000,areFieldsSet=true,areAllFieldsSet=true,lenient=true,zone=sun.util.calendar.ZoneInfo[id="GMT",offset=0,dstSavings=0,useDaylight=false,transitions=0,lastRule=null],firstDayOfWeek=1,minimalDaysInFirstWeek=1,ERA=1,YEAR=2018,MONTH=10,WEEK_OF_YEAR=48,WEEK_OF_MONTH=5,DAY_OF_MONTH=27,DAY_OF_YEAR=331,DAY_OF_WEEK=3,DAY_OF_WEEK_IN_MONTH=4,AM_PM=1,HOUR=0,HOUR_OF_DAY=12,MINUTE=17,SECOND=42,MILLISECOND=0,ZONE_OFFSET=0,DST_OFFSET=0]' numberRecordsProcessed='0' numberRecordsFailed='0' totalProcessingTime='0' apiActiveProcessingTime='0' apexProcessingTime='0' ] 2018-11-27 23:17:44,502 XXXXXX_to_salesforce_demo/XXXXXX ERROR Can't process batch ProductionPipelineRunner *admin Spool Directory Runner - 0 com.streamsets.pipeline.api.StageException: FORCE_13 - Error writing to Salesforce: , InvalidSessionId : Invalid session id at com.streamsets.pipeline.stage.destination.salesforce.ForceBulkWriter.processJob(ForceBulkWriter.java:167) at com.streamsets.pipeline.stage.destination.salesforce.ForceBulkWriter.writeBatch(ForceBulkWriter.java:141) at com.streamsets.pipeline.stage.destination.salesforce.ForceTarget.write(ForceTarget.java:200) at com.streamsets.pipeline.configurablestage.DTarget.write(DTarget.java:34) at com.streamsets.datacollector.runner.StageRuntime$2.call(StageRuntime.java:252) at com.streamsets.datacollector.runner.StageRuntime$2.call(StageRuntime.java:236) at com.streamsets.pipeline.api.impl.CreateByRef.call(CreateByRef.java:40) at com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:194) at com.streamsets.datacollector.runner.StageRuntime.execute(StageRuntime.java:263) at com.streamsets.datacollector.runner.StagePipe.process(StagePipe.java:225) at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.processPipe(ProductionPipelineRunner.java:760) at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.lambda$runSourceLessBatch$3(ProductionPipelineRunner.java:788) at com.streamsets.datacollector.runner.PipeRunner.executeBatch(PipeRunner.java:132) at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.runSourceLessBatch(ProductionPipelineRunner.java:787) at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunner.processBatch(ProductionPipelineRunner.java:468) at com.streamsets.datacollector.runner.StageRuntime$4.run(StageRuntime.java:327) at java.security.AccessController.doPrivileged(Native Method) at com.streamsets.datacollector.runner.StageRuntime.processBatch(StageRuntime.java:323) at com.streamsets.datacollector.runner.StageContext.processBatch(StageContext.java:248) at com.streamsets.pipeline.lib.dirspooler.SpoolDirRunnable.produce(SpoolDirRunnable.java:299) at com ... (more)

edit retag flag offensive close merge delete