You are not logged in.

Unanswered posts



Important! This site has been replaced. All content here is read-only. Please visit our brand-new community at https://community.talend.com/. We look forward to hearing from you there!



#1 2017-03-14 13:32:02

vaibhav.bandge
Member
6 posts

vaibhav.bandge said:

How to run jobs in parallel using tparallelize component?

Tags: [error]

Hi,
I am using a java routine in my project which download the data of the object from Sales Force, and load that data into sql server tables one by one each table . 
I want to do this process parallel so that 2 tables load at a time using tParallelize component . My design as follows-
 


My java Routine is called inside the tRunJob components at a time after setting the parameters correctly in context using "Set Context " as shown above.

I get following error during execution -

[ERROR] 2017-03-14 04:43:12,286: {routines.GenerateSFData} - Download Data -  [AsyncApiException  exceptionCode='InvalidSessionId'
 exceptionMessage='Invalid session id'
]

Closing job..l
[AsyncApiException  exceptionCode='InvalidSessionId'
 exceptionMessage='Invalid session id'
]

    at com.sforce.async.BulkConnection.parseAndThrowException(BulkConnection.java:180)
    at com.sforce.async.BulkConnection.doHttpGet(BulkConnection.java:744)
    at com.sforce.async.BulkConnection.getBatchResultStream(BulkConnection.java:609)
    at com.sforce.async.BulkConnection.getQueryResultList(BulkConnection.java:639)
    at com.sforce.async.BulkConnection.getQueryResultList(BulkConnection.java:635)
    at routines.GenerateSFData.downloadCSVFiles(GenerateSFData.java:588)
    at routines.GenerateSFData.retrieveData(GenerateSFData.java:348)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.tJava_4Process(Ava_SF2DB.java:6887)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.tFileList_1Process(Ava_SF2DB.java:4806)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.tFileList_6Process(Ava_SF2DB.java:12956)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.tJava_1Process(Ava_SF2DB.java:12599)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.tMSSqlInput_3Process(Ava_SF2DB.java:12448)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.tSetGlobalVar_1Process(Ava_SF2DB.java:11989)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.runJobInTOS(Ava_SF2DB.java:22973)
    at avasf.ava_sf2db_0_1.Ava_SF2DB.runJob(Ava_SF2DB.java:22287)
    at avasf.avasf_mainjob_copy_0_1.AvaSF_MainJob_Copy.tRunJob_1Process(AvaSF_MainJob_Copy.java:5913)
    at avasf.avasf_mainjob_copy_0_1.AvaSF_MainJob_Copy$3.run(AvaSF_MainJob_Copy.java:4888)
[ERROR] 2017-03-14 04:43:12,489: {routines.GenerateSFData} - Exception while closing the job - closeJob method -  [AsyncApiException  exceptionCode='InvalidSessionId'
 exceptionMessage='Invalid session id'
]

Offline

#2 2017-03-14 14:48:42

TRF
Member
388 posts

TRF said:

Re: How to run jobs in parallel using tparallelize component?

Hi,
exceptionCode='InvalidSessionId' means you're not connected to Salesforce.
Regards,
TRF

Offline

#3 2017-04-06 07:44:24

vaibhav.bandge
Member
6 posts

vaibhav.bandge said:

Re: How to run jobs in parallel using tparallelize component?

Thanks TRF for you reply,
I have resolved connection issue as one of the object starts executing but when it ends my routine call is also closed so gives -
[ERROR] 2017-03-14 04:43:12,489: {routines.GenerateSFData} - Exception while closing the job - closeJob method -  [AsyncApiException  exceptionCode='InvalidSessionId'
I want to do this process parallel so that 2 tables load at a time using tParallelize component, can u to solve this issue?

Thanks,
Vaibhav

Offline

Board footer

Talend Contributor Agreement - Talend Website Privacy Policy