topic Re: deadlock in load test with db2 in Alfresco Archive

deadlock in load test with db2

long_187 — Mon, 08 Apr 2013 11:20:56 GMT

Load Test: 2 concurrent; db2 v9.7; activiti v5.12 weblogic 10deadlock occuerd:1190995 2013-04-08 16:48:08.176 [ACTIVE] ExecuteThread: '541' for queue: 'weblogic.kernel.Default (self-tuning)' true POST /aps/SubmitApsTask.param [f=SubmitApsTask, tid=, ip=197.3.176.106, sid=] ERROR c.t.f.f.s.Except

Re: deadlock in load test with db2

ronald_van_kuij — Tue, 09 Apr 2013 00:06:59 GMT

Adding a unittest that demonstrates the problem would help tremendously…

Re: deadlock in load test with db2

jbarrez — Wed, 10 Apr 2013 14:11:15 GMT

Yes indeed, without it it gets very hard guessing what exactly is tested.

Re: deadlock in load test with db2

long_187 — Mon, 15 Apr 2013 08:26:20 GMT

ApsProcess.bpmn:

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:smileysurprised:mgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:smileysurprised:mgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.cmbc.com.cn/test">
  <process id="apsProcess" name="网点预处理流程" isExecutable="true" activiti:candidateStarterGroups="businessManager">
    <documentation>网点预处理流程</documentation>
    <startEvent id="startevent" name="Start" activiti:initiator="initiator"></startEvent>
    <userTask id="approveTask" name="审核经理审核" activiti:candidateGroups="approver">
      <extensionElements>
        <activiti:formProperty id="name" name="姓名" type="string" expression="${name}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="sex" name="性别" type="enum" expression="${sex}" writable="false">
          <activiti:value id="male" name="男"></activiti:value>
          <activiti:value id="female" name="女"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idType" name="证件类型" type="enum" expression="${idType}" writable="false">
          <activiti:value id="identification" name="身份证"></activiti:value>
          <activiti:value id="officerCard" name="军官证"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idNum" name="证件号码" type="string" expression="${idNum}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="cardNum" name="卡号" type="string" expression="${cardNum}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="businessType" name="业务类型" type="string" expression="${businessType}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="amount" name="交易金额" type="string" expression="${amount}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="approved" name="是否审核通过" type="enum" required="true">
          <activiti:value id="true" name="是"></activiti:value>
          <activiti:value id="false" name="否"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="approveAdvice" name="审核意见" type="string"></activiti:formProperty>
      </extensionElements>
    </userTask>
    <exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway"></exclusiveGateway>
    <sequenceFlow id="approveGatewayFlow" sourceRef="approveTask" targetRef="exclusivegateway1"></sequenceFlow>
    <sequenceFlow id="notApprovedFlow" name="审核不通过" sourceRef="exclusivegateway1" targetRef="commitTask">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${approved==false}]]></conditionExpression>
    </sequenceFlow>
    <parallelGateway id="parallelgateway1" name="Parallel Gateway"></parallelGateway>
    <sequenceFlow id="approvedNextFlow" name="审核通过" sourceRef="exclusivegateway1" targetRef="parallelgateway1">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${approved==true}]]></conditionExpression>
    </sequenceFlow>
    <serviceTask id="prepCondition1" name="准备关键条件1" activiti:class="com.cmbc.aps.activiti.PrepareConditionOneDelegate"></serviceTask>
    <userTask id="prepCondition3" name="准备关键条件3" activiti:assignee="${initiator}">
      <extensionElements>
        <activiti:taskListener event="complete" class="com.cmbc.aps.activiti.PrepCondition3TaskListener"></activiti:taskListener>
      </extensionElements>
    </userTask>
    <sequenceFlow id="toPrepCondition3Flow" sourceRef="parallelgateway1" targetRef="prepCondition3"></sequenceFlow>
    <sequenceFlow id="toPrepCondition1Flow" sourceRef="parallelgateway1" targetRef="prepCondition1"></sequenceFlow>
    <userTask id="processTask" name="处理任务" activiti:candidateGroups="counter">
      <extensionElements>
        <activiti:formProperty id="name" name="姓名" type="string" expression="${name}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="sex" name="性别" type="enum" expression="${sex}" writable="false">
          <activiti:value id="male" name="男"></activiti:value>
          <activiti:value id="female" name="女"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idType" name="证件类型" type="enum" expression="${idType}" writable="false">
          <activiti:value id="identification" name="身份证"></activiti:value>
          <activiti:value id="officerCard" name="军官证"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idNum" name="证件号码" type="string" expression="${idNum}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="cardNum" name="卡号" type="string" expression="${cardNum}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="businessType" name="业务类型" type="string" expression="${businessType}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="amount" name="交易金额" type="string" expression="${amount}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="successed" name="是否处理成功" type="enum" required="true">
          <activiti:value id="true" name="是"></activiti:value>
          <activiti:value id="false" name="否"></activiti:value>
        </activiti:formProperty>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow2" sourceRef="prepCondition1" targetRef="parallelgateway2"></sequenceFlow>
    <sequenceFlow id="flow4" sourceRef="prepCondition3" targetRef="parallelgateway2"></sequenceFlow>
    <parallelGateway id="parallelgateway2" name="Parallel Gateway"></parallelGateway>
    <sequenceFlow id="flow5" sourceRef="parallelgateway2" targetRef="processTask"></sequenceFlow>
    <exclusiveGateway id="exclusivegateway2" name="Exclusive Gateway"></exclusiveGateway>
    <sequenceFlow id="flow6" sourceRef="processTask" targetRef="exclusivegateway2"></sequenceFlow>
    <endEvent id="endevent1" name="End"></endEvent>
    <sequenceFlow id="toFinish" name="处理成功" sourceRef="exclusivegateway2" targetRef="endevent1">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${successed==true}]]></conditionExpression>
    </sequenceFlow>
    <userTask id="exceptionHandle" name="异常处理" activiti:candidateGroups="exceptionHandler">
      <extensionElements>
        <activiti:formProperty id="name" name="姓名" type="string" expression="${name}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="sex" name="性别" type="enum" expression="${sex}" writable="false">
          <activiti:value id="male" name="男"></activiti:value>
          <activiti:value id="female" name="女"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idType" name="证件类型" type="enum" expression="${idType}" writable="false">
          <activiti:value id="identification" name="身份证"></activiti:value>
          <activiti:value id="officerCard" name="军官证"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idNum" name="证件号码" type="string" expression="${idNum}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="cardNum" name="卡号" type="string" expression="${cardNum}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="businessType" name="业务类型" type="string" expression="${businessType}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="amount" name="交易金额" type="string" expression="${amount}" writable="false"></activiti:formProperty>
        <activiti:formProperty id="isSuccessed" type="string" default="业务未处理成功"></activiti:formProperty>
        <activiti:formProperty id="returnTo" name="任务退回给" type="enum" required="true">
          <activiti:value id="approver" name="审核经理"></activiti:value>
          <activiti:value id="businessManager" name="业务经理"></activiti:value>
        </activiti:formProperty>
      </extensionElements>
    </userTask>
    <sequenceFlow id="toExceptionHandle" name="处理不成功" sourceRef="exclusivegateway2" targetRef="exceptionHandle">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${successed==false}]]></conditionExpression>
    </sequenceFlow>
    <sequenceFlow id="toStartFlow" name="退回给业务经理" sourceRef="exceptionHandle" targetRef="commitTask">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${returnTo=="businessManager"}]]></conditionExpression>
    </sequenceFlow>
    <sequenceFlow id="toApproverFlow" name="退回给审核经理" sourceRef="exceptionHandle" targetRef="approveTask">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${returnTo=="approver"}]]></conditionExpression>
    </sequenceFlow>
    <scriptTask id="prepCondition2" name="准备关键条件2" scriptFormat="groovy">
      <script>condition2 = "OK";</script>
    </scriptTask>
    <sequenceFlow id="toPrepCondition2" sourceRef="parallelgateway1" targetRef="prepCondition2"></sequenceFlow>
    <sequenceFlow id="flow8" sourceRef="prepCondition2" targetRef="parallelgateway2"></sequenceFlow>
    <userTask id="commitTask" name="业务经理提交任务" activiti:candidateGroups="businessManager">
      <extensionElements>
        <activiti:formProperty id="name" name="姓名" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="sex" name="性别" type="enum" required="true">
          <activiti:value id="male" name="男"></activiti:value>
          <activiti:value id="female" name="女"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idType" name="证件类型" type="enum" required="true">
          <activiti:value id="identification" name="身份证"></activiti:value>
          <activiti:value id="officerCard" name="军官证"></activiti:value>
        </activiti:formProperty>
        <activiti:formProperty id="idNum" name="证件号码" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="cardNum" name="卡号" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="businessType" name="业务类型" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="amount" name="交易金额" type="string" required="true"></activiti:formProperty>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow9" sourceRef="startevent" targetRef="commitTask"></sequenceFlow>
    <sequenceFlow id="flow10" sourceRef="commitTask" targetRef="approveTask"></sequenceFlow>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_apsProcess">
    <bpmndi:BPMNPlane bpmnElement="apsProcess" id="BPMNPlane_apsProcess">
      <bpmndi:BPMNShape bpmnElement="startevent" id="BPMNShape_startevent">
        <omgdc:Bounds height="35.0" width="35.0" x="30.0" y="170.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="approveTask" id="BPMNShape_approveTask">
        <omgdc:Bounds height="55.0" width="105.0" x="241.0" y="160.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="exclusivegateway1" id="BPMNShape_exclusivegateway1">
        <omgdc:Bounds height="40.0" width="40.0" x="380.0" y="167.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="parallelgateway1" id="BPMNShape_parallelgateway1">
        <omgdc:Bounds height="40.0" width="40.0" x="490.0" y="167.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="processTask" id="BPMNShape_processTask">
        <omgdc:Bounds height="55.0" width="105.0" x="780.0" y="160.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="parallelgateway2" id="BPMNShape_parallelgateway2">
        <omgdc:Bounds height="40.0" width="40.0" x="698.0" y="167.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="exclusivegateway2" id="BPMNShape_exclusivegateway2">
        <omgdc:Bounds height="40.0" width="40.0" x="812.0" y="247.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="919.0" y="250.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="exceptionHandle" id="BPMNShape_exceptionHandle">
        <omgdc:Bounds height="55.0" width="105.0" x="241.0" y="321.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="prepCondition3" id="BPMNShape_prepCondition3">
        <omgdc:Bounds height="55.0" width="105.0" x="566.0" y="240.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="prepCondition2" id="BPMNShape_prepCondition2">
        <omgdc:Bounds height="55.0" width="105.0" x="566.0" y="160.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="prepCondition1" id="BPMNShape_prepCondition1">
        <omgdc:Bounds height="55.0" width="105.0" x="566.0" y="80.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="commitTask" id="BPMNShape_commitTask">
        <omgdc:Bounds height="55.0" width="105.0" x="100.0" y="160.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="notApprovedFlow" id="BPMNEdge_notApprovedFlow">
        <omgdi:waypoint x="400.0" y="167.0"></omgdi:waypoint>
        <omgdi:waypoint x="400.0" y="90.0"></omgdi:waypoint>
        <omgdi:waypoint x="170.0" y="90.0"></omgdi:waypoint>
        <omgdi:waypoint x="152.0" y="90.0"></omgdi:waypoint>
        <omgdi:waypoint x="152.0" y="160.0"></omgdi:waypoint>
        <bpmndi:BPMNLabel>
          <omgdc:Bounds height="14.0" width="100.0" x="-36.0" y="1.0"></omgdc:Bounds>
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="approvedNextFlow" id="BPMNEdge_approvedNextFlow">
        <omgdi:waypoint x="420.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="490.0" y="187.0"></omgdi:waypoint>
        <bpmndi:BPMNLabel>
          <omgdc:Bounds height="14.0" width="100.0" x="-30.0" y="0.0"></omgdc:Bounds>
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
        <omgdi:waypoint x="671.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="718.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="718.0" y="207.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
        <omgdi:waypoint x="738.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="780.0" y="187.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
        <omgdi:waypoint x="671.0" y="107.0"></omgdi:waypoint>
        <omgdi:waypoint x="718.0" y="107.0"></omgdi:waypoint>
        <omgdi:waypoint x="718.0" y="167.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
        <omgdi:waypoint x="832.0" y="215.0"></omgdi:waypoint>
        <omgdi:waypoint x="832.0" y="247.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow8" id="BPMNEdge_flow8">
        <omgdi:waypoint x="671.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="698.0" y="187.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toStartFlow" id="BPMNEdge_toStartFlow">
        <omgdi:waypoint x="241.0" y="348.0"></omgdi:waypoint>
        <omgdi:waypoint x="152.0" y="348.0"></omgdi:waypoint>
        <omgdi:waypoint x="152.0" y="215.0"></omgdi:waypoint>
        <bpmndi:BPMNLabel>
          <omgdc:Bounds height="14.0" width="100.0" x="-44.0" y="-5.0"></omgdc:Bounds>
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toApproverFlow" id="BPMNEdge_toApproverFlow">
        <omgdi:waypoint x="293.0" y="321.0"></omgdi:waypoint>
        <omgdi:waypoint x="293.0" y="215.0"></omgdi:waypoint>
        <bpmndi:BPMNLabel>
          <omgdc:Bounds height="14.0" width="100.0" x="10.0" y="0.0"></omgdc:Bounds>
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toExceptionHandle" id="BPMNEdge_toExceptionHandle">
        <omgdi:waypoint x="832.0" y="287.0"></omgdi:waypoint>
        <omgdi:waypoint x="832.0" y="348.0"></omgdi:waypoint>
        <omgdi:waypoint x="346.0" y="348.0"></omgdi:waypoint>
        <bpmndi:BPMNLabel>
          <omgdc:Bounds height="14.0" width="100.0" x="10.0" y="0.0"></omgdc:Bounds>
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toFinish" id="BPMNEdge_toFinish">
        <omgdi:waypoint x="852.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="919.0" y="267.0"></omgdi:waypoint>
        <bpmndi:BPMNLabel>
          <omgdc:Bounds height="14.0" width="100.0" x="-31.0" y="1.0"></omgdc:Bounds>
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toPrepCondition1Flow" id="BPMNEdge_toPrepCondition1Flow">
        <omgdi:waypoint x="510.0" y="167.0"></omgdi:waypoint>
        <omgdi:waypoint x="509.0" y="107.0"></omgdi:waypoint>
        <omgdi:waypoint x="566.0" y="107.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toPrepCondition3Flow" id="BPMNEdge_toPrepCondition3Flow">
        <omgdi:waypoint x="510.0" y="207.0"></omgdi:waypoint>
        <omgdi:waypoint x="509.0" y="267.0"></omgdi:waypoint>
        <omgdi:waypoint x="566.0" y="267.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="toPrepCondition2" id="BPMNEdge_toPrepCondition2">
        <omgdi:waypoint x="530.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="566.0" y="187.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow9" id="BPMNEdge_flow9">
        <omgdi:waypoint x="65.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="100.0" y="187.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow10" id="BPMNEdge_flow10">
        <omgdi:waypoint x="205.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="241.0" y="187.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="approveGatewayFlow" id="BPMNEdge_approveGatewayFlow">
        <omgdi:waypoint x="346.0" y="187.0"></omgdi:waypoint>
        <omgdi:waypoint x="380.0" y="187.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions>

Unit test, ProcessTestApsProcess.java:

package org.activiti.designer.test;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;

import java.util.HashMap;
import java.util.Map;

import org.activiti.engine.RuntimeService;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.activiti.engine.test.ActivitiRule;
import org.databene.contiperf.PerfTest;
import org.databene.contiperf.junit.ContiPerfRule;
import org.junit.Assert;
import org.junit.Rule;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:activiti.cfg.xml")
public class ProcessTestApsProcess {
 
 Logger logger = LoggerFactory.getLogger(getClass());
 
 @Autowired
 @Rule
 public ActivitiRule activitiRule;
 
 @Rule
 public ContiPerfRule contiPerfRule = new ContiPerfRule();

 @Test
 @PerfTest(invocations = 500 , threads = 5)
 //@Deployment(resources={"diagrams/ApsProcess.bpmn", "diagrams/ApsProcess.png"})
 public void startProcess() throws Exception {
  
  try {
   RuntimeService runtimeService = activitiRule.getRuntimeService();
   
   //开预处理流程并提交任务
   activitiRule.getIdentityService().setAuthenticatedUserId("chenlong4");
   
   //String businessKey = "000004";
   ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("apsProcess");
   assertNotNull(processInstance.getId());
   System.out.println("id " + processInstance.getId() + " " + processInstance.getProcessDefinitionId());
   
   final String processInstanceId = processInstance.getId();
   
   //业务经理提交任务
   Task businessManagerTask = activitiRule.getTaskService().createTaskQuery()
        .processInstanceId(processInstanceId)
        .taskCandidateGroup("businessManager")
        .active()
        .singleResult();
   
   activitiRule.getTaskService().claim(businessManagerTask.getId(), "chenlong4");
   
   Map<String, String> variableMap = new HashMap<String, String>();
   variableMap.put("name", "姓名");
   variableMap.put("sex", "male");
   variableMap.put("idType", "identification");
   variableMap.put("idNum", "430304XXXXXXXXXXXX");
   variableMap.put("cardNum", "6226220109108899");
   variableMap.put("businessType", "测试业务");
   variableMap.put("amount", "5000");
   activitiRule.getFormService().submitTaskFormData(businessManagerTask.getId(), variableMap);
   
   //审批经理审批
   Task approveTask = activitiRule.getTaskService().createTaskQuery()
        .processInstanceId(processInstanceId)
        .taskCandidateGroup("approver")
        .active()
        .singleResult();
   
   activitiRule.getTaskService().claim(approveTask.getId(), "xiaohong2");
   
   String approved = "true";
   Map<String, String> approvedProperties = new HashMap<String, String>(); 
   approvedProperties.put("approved", approved);
   activitiRule.getFormService().submitTaskFormData(approveTask.getId(), approvedProperties);
   
   //准备关键条件3
   Task prepareCondition3Task = activitiRule.getTaskService().createTaskQuery()
        .processInstanceId(processInstanceId)
        .taskAssignee("chenlong4")
        .active()
        .singleResult();
   
   activitiRule.getTaskService().complete(prepareCondition3Task.getId());
   
   //柜员处理任务
   Task processTask = activitiRule.getTaskService().createTaskQuery()
        .processInstanceId(processInstanceId)
        //.processInstanceBusinessKey(businessKey)
        .taskCandidateGroup("counter")
        .active()
        .singleResult();

   
   activitiRule.getTaskService().claim(processTask.getId(), "chenlong4");
   
   String successed = "true";
   Map<String, String> processProperties = new HashMap<String, String>(); 
   processProperties.put("successed", successed);
   activitiRule.getFormService().submitTaskFormData(processTask.getId(), processProperties);
   
   //完成
   
   
   processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
   assertEquals(true, processInstance == null);
   
//   HistoricProcessInstance hiProcessInstance = activitiRule.getHistoryService().createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
//   assertNotNull(hiProcessInstance);
  } catch (Throwable e) {
   logger.error("流程执行失败", e);
   Assert.fail(e.getMessage());
  }
 }
 
}

Re: deadlock in load test with db2

long_187 — Mon, 15 Apr 2013 08:31:01 GMT

Running Unit test "ProcessTestApsProcess.java" With only 2 thread will occur db2 deadlock, and the deadlock caused by method TaskService.submitTaskFormData()

Re: deadlock in load test with db2

long_187 — Mon, 15 Apr 2013 08:44:17 GMT

I delete all forignkeys on tables ACT_RU_* the deadlock is gone.

I use db2 command "db2 get snapshot locks on db ACTIVITI" can find table ACT_RU_INDENTITY_LINK adnd ACT_RU_TASK are in "locked wait" status.
But I not know the real reason of the deadlock occured, why these tables will locked wait running in multiple thread?

Re: deadlock in load test with db2

jbarrez — Tue, 16 Apr 2013 10:58:54 GMT

Hmm. I got a feeling about this one: we released yesterday Activiti 5.12.1 which contains a bugfix related to the area you mention here. Could you give the new version a try and report back if the error still exists?

Re: deadlock in load test with db2

long_187 — Wed, 17 Apr 2013 07:10:32 GMT

Activiti 5.12.1 did not work. I have retry my unit test with Activiti 5.12.1, still deadlock, and I have deleted all forignkeys on tables ACT_RU_* the deadlock is gone.

Re: deadlock in load test with db2

jbarrez — Thu, 18 Apr 2013 11:04:34 GMT

<i>Activiti 5.12.1 did not work. I have retry my unit test with Activiti 5.12.1, still deadlock, </i>

Damn. I really thought it would have fixed it. Bummers.

<i>and I have deleted all forignkeys on tables ACT_RU_* the deadlock is gone.</i>

That's really strange that it deadlocks because of foreign keys. That doesn't really makes sense.
Do you know which foreign key specifically?

Re: deadlock in load test with db2

long_187 — Fri, 19 Apr 2013 09:11:56 GMT

It is not strange that it deadlocks because of foreign keys in db2.

But I think the real reason of deadlock may not be because of the foreign keys.

I have repeatedly run the unit tests ，and found these foreign keys cause the deadlock:

ALTER TABLE SCM_ACTIVITI.ACT_RU_IDENTITYLINK DROP CONSTRAINT ACT_FK_TSKASS_TASK;

ALTER TABLE SCM_ACTIVITI.ACT_RU_IDENTITYLINK DROP CONSTRAINT ACT_FK_IDL_PROCINST;

ALTER TABLE SCM_ACTIVITI.ACT_RU_TASK DROP CONSTRAINT ACT_FK_TASK_EXE;

ALTER TABLE SCM_ACTIVITI.ACT_RU_TASK DROP CONSTRAINT ACT_FK_TASK_PROCINST;

ALTER TABLE SCM_ACTIVITI.ACT_RU_VARIABLE DROP CONSTRAINT ACT_FK_VAR_EXE;

ALTER TABLE SCM_ACTIVITI.ACT_RU_VARIABLE DROP CONSTRAINT ACT_FK_VAR_PROCINST;

ALTER TABLE SCM_ACTIVITI.ACT_RU_EXECUTION DROP CONSTRAINT ACT_FK_EXE_PARENT;

ALTER TABLE SCM_ACTIVITI.ACT_RU_EXECUTION DROP CONSTRAINT ACT_FK_EXE_PROCINST;

ALTER TABLE SCM_ACTIVITI.ACT_RU_EXECUTION DROP CONSTRAINT ACT_FK_EXE_SUPER;

Re: deadlock in load test with db2

jbarrez — Mon, 22 Apr 2013 09:16:54 GMT

> It is not strange that it deadlocks because of foreign keys in db2.

Can you elaborate on that? Why would a database not be smart enough to cope with this? Unless the data that is inserted depends on something that is inserted at the same time?

That seems like really way too much foreign keys … foreign keys are there for a reason.
What isolation level are you running your tests on?

Re: deadlock in load test with db2

long_187 — Mon, 01 Jul 2013 03:23:03 GMT

Hi jbarrez:

I have find out the reason of it deadlocks because of foreign keys in db2:
The table ACT_RU_IDENTITYLINK has a foreign key _TASK_ID refference to the table ACT_RU_TASK(ID_). If delete a task from ACT_RU_TASK, db2 will execute TB SCAN(Table Scan) on ACT_RU_IDENTITYLINK and lock the ACT_RU_IDENTITYLINK table. If two thread do TB SCAN at the same time, the deadlock occur.
Then, I create a index on ACT_RU_IDENTITYLINK(_TASK_ID), db2 will not execute TB SCAN instead of IX SCAN(Index SCAN) and only lock the matched row.
In other words, Create index on each foreign keys, can resovle the deadlock.

Indexies to append:
create index ACT_IDX_EVENT_SUBSCR_EXEC_ID on ACT_RU_EVENT_SUBSCR(EXECUTION_ID_);

create index ACT_IDX_EXEC_PARENT_ID on ACT_RU_EXECUTION(PARENT_ID_);
create index ACT_IDX_EXEC_PROC_DEF_ID on ACT_RU_EXECUTION(PROC_DEF_ID_);
create index ACT_IDX_EXEC_PROC_INST_ID on ACT_RU_EXECUTION(PROC_INST_ID_);
create index ACT_IDX_EXEC_SUPER_EXEC on ACT_RU_EXECUTION(SUPER_EXEC_);

create index ACT_IDX_IDENT_LNK_TASK_ID on ACT_RU_IDENTITYLINK(TASK_ID_);
create index ACT_IDX_IDENT_LNK_PROC_INST_ID on ACT_RU_IDENTITYLINK(PROC_INST_ID_);

create index ACT_IDX_JOB_EXCEPTION_STACK_ID on ACT_RU_JOB(EXCEPTION_STACK_ID_);

create index ACT_IDX_TASK_EXECUTION_ID on ACT_RU_TASK(EXECUTION_ID_);
create index ACT_IDX_TASK_PROC_DEF_ID on ACT_RU_TASK(PROC_DEF_ID_);
create index ACT_IDX_TASK_PROC_INST_ID on ACT_RU_TASK(PROC_INST_ID_);

create index ACT_IDX_VARIABLE_BYTEARRAY_ID on ACT_RU_VARIABLE(BYTEARRAY_ID_);
create index ACT_IDX_VARIABLE_EXECUTION_ID on ACT_RU_VARIABLE(EXECUTION_ID_);
create index ACT_IDX_VARIABLE_PROC_INST_ID on ACT_RU_VARIABLE(PROC_INST_ID_);

Re: deadlock in load test with db2

jbarrez — Mon, 01 Jul 2013 08:51:42 GMT

I saw your JIRA issue (thx) and will check/react there.