You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by GitBox <gi...@apache.org> on 2021/02/22 04:01:22 UTC

[GitHub] [incubator-dolphinscheduler] xiashao1980 opened a new issue #4835: Instances can not execute in parallel mode under ds1.3.4

xiashao1980 opened a new issue #4835:
URL: https://github.com/apache/incubator-dolphinscheduler/issues/4835


   Hi guys,
   
   I have installed ds1.3.4. There are two workers (A and B) in my system.  And I set work.exec.threads to 1, then I called ds API 'startProcessInstance' to start a few instances.  But all tasks were executed under work A.  And if I start some instances later, they will be executed under work B.
   
   I call ds API with follow Python code:
   form_data = {
           "processDefinitionId": flowid,
           "scheduleTime": "",
           "failureStrategy": "END",
           "warningType": "NONE",
           "warningGroupId": 0,
           "execType": "START_PROCESS",
           #"startNodeList": "",
           #"taskDependType": "TASK_POST",
           "runMode": "RUN_MODE_PARALLEL",  #RUN_MODE_SERIAL, RUN_MODE_PARALLEL
           "processInstancePriority": "MEDIUM",
           #"receivers": "",
           #"receiversCc": "",
           #"workerGroupId": -1,
           "userData": userdata,
           "subTitle": title
       }
   
    Could ds assign tasks to multiple workers in parallel mode? Are there any problems that exist in my code?
   
   Thanks.
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org