pr??https://github.com/apache/incubator-dolphinscheduler/pull/3728




------------------ ???????? ------------------
??????:                                                                         
                                               "dev"                            
                                                        
<[email protected]&gt;;
????????:&nbsp;2020??9??14??(??????) ????2:10
??????:&nbsp;"dev"<[email protected]&gt;;
????:&nbsp;"gabrywu"<[email protected]&gt;;
????:&nbsp;Re: ??????[Feature][process_definition] process definition need to 
support parallel or serial choose. and parallel mode support wait queue length



good job
I like this feature



Best Regards
---------------
DolphinScheduler(Incubator) PPMC
Lidong Dai ??????
[email protected]
---------------


yongqing <[email protected]&gt; ??2020??9??14?????? ????1:40??????

&gt; why I add two cloums in table t_ds_process_definition:
&gt;
&gt; 1??in process,need to solve serial run and serial run command can set wait
&gt; queue length.
&gt;
&gt; 2??after later??we need to statistics serial or parallel&amp;nbsp;commands 
for
&gt; every projet or every process definition.
&gt;
&gt;
&gt;
&gt;
&gt; ------------------ ???????? ------------------
&gt; ??????:
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 "dev"
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <
&gt; [email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??9??14??(??????) ????1:20
&gt; ??????:&amp;nbsp;"[email protected]"<
&gt; [email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: ??????[Feature][process_definition] process definition 
need to
&gt; support parallel or serial choose. and parallel mode support wait queue
&gt; length
&gt;
&gt;
&gt;
&gt; I think there??s no need to add the is_parallel column, because the
&gt; parallelism is the base function of the workflow or task.
&gt; Serial is just the speciall case when parallelism is 1.
&gt;
&gt;
&gt; From: yongqing <[email protected]&amp;gt;
&gt; Reply-To: "[email protected]" <
&gt; [email protected]&amp;gt;
&gt; Date: Monday, September 14, 2020 at 11:28
&gt; To: dev <[email protected]&amp;gt;
&gt; Subject: ??????[Feature][process_definition] process definition need to
&gt; support parallel or serial choose. and parallel mode support wait queue
&gt; length
&gt;
&gt; other company need this function too??
&gt; [cid:[email protected]]
&gt;
&gt; ------------------ ???????? ------------------
&gt; ??????: "yongqing" <[email protected]&amp;gt;;
&gt; ????????: 2020??9??14??(??????) ????10:32
&gt; ??????: "dev"<[email protected]&amp;gt;;
&gt; ????: [Feature][process_definition] process definition need to support
&gt; parallel or serial choose. and parallel mode support wait queue length
&gt;
&gt; hi,all
&gt; our company need this funcation. so we add this funcation into apache. and
&gt; our company ??s all old tasks will be switched to 
incubator-dolphinscheduler
&gt; system.
&gt;
&gt; process definition need to support parallel or serial choose.
&gt; if is serial in dispatch??need to the previous process_instance execute
&gt; complete??next process_instance can to run??
&gt;
&gt; ?????????????????????????????? 
????????????????????????????????????????????????????????????????????????????
&gt; ??????????????????????????????????????????????????????????????????????????.
&gt;
&gt; &amp;nbsp;in database, table t_ds_process_definition need add
&gt; cloum:is_parallel,serial_command_lengh. sql script need to exec in 
database.
&gt;
&gt; alter table t_ds_process_definition add is_parallel tinyint default '1'
&gt; comment '0:serial,1:parallel';
&gt; alter table t_ds_process_definition add serial_command_lengh bigint
&gt; default '0' comment 'serial exec command lengh';
&gt;
&gt; why I add two cloums in table t_ds_process_definition:
&gt;
&gt; 1??in process,need to solve serial run and serial run command can set wait
&gt; queue length.
&gt;
&gt; 2??after later??we need to statistics serial commands for every projet or
&gt; every processdef.
&gt;
&gt; this function has uesd in our company. I hope can merger this function to
&gt; apache??and in future our company can use more new apache release version??
&gt;
&gt; [Image removed by sender.]
&gt;
&gt; [Image removed by sender.]
&gt;
&gt; [Image removed by sender.]
&gt;
&gt; [Image removed by sender.]
&gt;
&gt;
&gt; ------------------ Original ------------------
&gt; From: "dev-help" <[email protected]&amp;gt;;
&gt; Date: Mon, Sep 14, 2020 10:30 AM
&gt; To: "yongqing"<[email protected]&amp;gt;;
&gt; Subject: WELCOME to [email protected]
&gt;
&gt; Hi! This is the ezmlm program. I'm managing the
&gt; [email protected] mailing list.
&gt;
&gt; I'm working for my owner, who can be reached
&gt; at [email protected].
&gt;
&gt; Acknowledgment: I have added the address
&gt;
&gt; &amp;nbsp;&amp;nbsp; [email protected]
&gt;
&gt; to the dev mailing list.
&gt;
&gt; Welcome to [email protected]!
&gt;
&gt; Please save this message so that you know the address you are
&gt; subscribed under, in case you later want to unsubscribe or change your
&gt; subscription address.
&gt;
&gt;
&gt; --- Administrative commands for the dev list ---
&gt;
&gt; I can handle administrative requests automatically. Please
&gt; do not send them to the list address! Instead, send
&gt; your message to the correct command address:
&gt;
&gt; To subscribe to the list, send a message to:
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt;
&gt; To remove your address from the list, send a message to:
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt;
&gt; Send mail to the following for info and FAQ for this list:
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt;
&gt; Similar addresses exist for the digest list:
&gt; &amp;nbsp;&amp;nbsp; 
<[email protected]&amp;gt;
&gt; &amp;nbsp;&amp;nbsp; 
<[email protected]&amp;gt;
&gt;
&gt; To get messages 123 through 145 (a maximum of 100 per request), mail:
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt;
&gt; To get an index with subject and author for messages 123-456 , mail:
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt;
&gt; They are always returned as sets of 100, max 2000 per request,
&gt; so you'll actually get 100-499.
&gt;
&gt; To receive all messages with the same subject as message 12345,
&gt; send a short message to:
&gt; &amp;nbsp;&amp;nbsp; <[email protected]&amp;gt;
&gt;
&gt; The messages should contain one line or word of text to avoid being
&gt; treated as sp@m, but I will ignore their content.
&gt; Only the ADDRESS you send to is important.
&gt;
&gt; You can start a subscription for an alternate address,
&gt; for example "[email protected]", just add a hyphen and your
&gt; address (with '=' instead of '@') after the command word:
&gt; <[email protected]&amp;gt;
&gt;
&gt; To stop subscription for this address, mail:
&gt; <[email protected]&amp;gt;
&gt;
&gt; In both cases, I'll send a confirmation message to that address. When
&gt; you receive it, simply reply to it to complete your subscription.
&gt;
&gt; If despite following these instructions, you do not get the
&gt; desired results, please contact my owner at
&gt; [email protected]. Please be patient, my owner is a
&gt; lot slower than I am ;-)
&gt;
&gt; --- Enclosed is a copy of the request I received.
&gt;
&gt; Return-Path: <[email protected]&amp;gt;
&gt; Received: (qmail 63012 invoked by uid 99); 14 Sep 2020 02:30:58 -0000
&gt; Received: from spamproc1-he-de.apache.org (HELO spamproc1-he-de.apache.org)
&gt; (116.203.196.100)
&gt; &amp;nbsp; &amp;nbsp; by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 14 Sep 
2020
&gt; 02:30:58 +0000
&gt; Received: from localhost (localhost [127.0.0.1])
&gt; by spamproc1-he-de.apache.org (ASF Mail Server at
&gt; spamproc1-he-de.apache.org) with ESMTP id F158D1FF42F
&gt; for <dev-sc.1600050589.nejmeipdgampgajmnign-597365581=
&gt; [email protected]&amp;gt;; Mon, 14 Sep 2020 02:30:57 +0000
&gt; (UTC)
&gt; X-Virus-Scanned: Debian amavisd-new at spamproc1-he-de.apache.org
&gt; X-Spam-Flag: NO
&gt; X-Spam-Score: 0.251
&gt; X-Spam-Level:
&gt; X-Spam-Status: No, score=0.251 tagged_above=-999 required=6.31
&gt; tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1,
&gt; DKIM_VALID_EF=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25,
&gt; FROM_EXCESS_BASE64=0.001, HTML_MESSAGE=0.2,
&gt; MSGID_FROM_MTA_HEADER=0.001, RCVD_IN_MSPIKE_H2=-0.001,
&gt; SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled
&gt; Authentication-Results: spamproc1-he-de.apache.org (amavisd-new);
&gt; dkim=pass (1024-bit key) header.d=qq.com
&gt; Received: from mx1-he-de.apache.org ([116.203.227.195])
&gt; by localhost (spamproc1-he-de.apache.org [116.203.196.100]) (amavisd-new,
&gt; port 10024)
&gt; with ESMTP id rY5rK6RNgRn8
&gt; for <dev-sc.1600050589.nejmeipdgampgajmnign-597365581=
&gt; [email protected]&amp;gt;;
&gt; Mon, 14 Sep 2020 02:30:56 +0000 (UTC)
&gt; Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=203.205.250.33;
&gt; helo=smtpbg506.qq.com; [email protected];
&gt; receiver=<UNKNOWN&amp;gt;
&gt; Received: from smtpbg506.qq.com (smtpbg506.qq.com [203.205.250.33])
&gt; by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with
&gt; ESMTPS id 918777F981
&gt; for <dev-sc.1600050589.nejmeipdgampgajmnign-597365581=
&gt; [email protected]&amp;gt;; Mon, 14 Sep 2020 02:30:52 +0000
&gt; (UTC)
&gt; DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=qq.com; s=s201512;
&gt; t=1600050644; bh=D2MtfdqVTxoUoQmH8WlfF8kJ7sSgPT0WH1fQQI+tZio=;
&gt; h=From:To:Subject:Mime-Version:Date:Message-ID;
&gt; b=UEkJkZ6Y0IGCKg18m1uorLOOgtAgZUZ56Aw+Dlq+oQpfXimlaqzUXt0T1RVXAkFK6
&gt; V2IXRuKPZqcsoi89sEAs4arBR87QaXM0TzeZur90MGca6H826CsVJHgqZKVYo4jxkH
&gt; d6pzT035XOnYtROn+cmy0scJIi1xkYlWeQXZ9KaU=
&gt; X-QQ-FEAT: I1MaI21uPakL5leDgr2Av3GuL20khCzx0PEShbXmOWDj4VUpqbw5pRSBRUT9i
&gt; qfVppOMk9eD+AJVXnPoj2ZqS+ho3Y+FCFAMHmrSvYj+h7Yjbn1QMqugHs1gILDyog57vQss
&gt; Nw0k4FqVd+sw0vKgf+zHcDwJe4smtTPgVUp10djo+ktfxLfeXCeWArZ94XG/l1OPNqjzhUx
&gt; ICMYiTcPye9WruDP+SnRdL4PmXDnVg8BQ2Y4SPMY9hkgU694EClb11jGrOMOcRfW+AcRp9P
&gt; eqV9NzZAaaPE72ri+K7YdRBpz21qsPo+fn8OZVfOyWnB2YZDSekhDx6vk=
&gt; X-QQ-SSF: 00000000000000F000000000000000Z
&gt; X-QQ-XMAILINFO:
&gt; OKV2ZMpe2FwgxneRb9v5pXv3/xLVYQnH3+sn/NPLv1H9tNkcDLw8f2ivo5MU8a
&gt;
&gt; 
8pzFZV58A2XdwZlXPnTLWrM8sO915dLPfpOkYelcwrDFUNoj4B5jkUga0fVhjVczNGsdSVpvix2d6
&gt;
&gt; 
2eEp4EtKdsEqXVQfNgZi/atwYRmY53quss8mvKa9GwF/3yHeTwUSmJeZIA8WXxRP5WdNtpmStFndM
&gt;
&gt; 
yM0UETduUv1tfDUAlOvshnjj/QJrNSQHOXC330QgkSlDZJZupmMQ8i/ZcmBh5BP6LbD8csecXYDR6
&gt;
&gt; 
q6sB9xNMWahzjuzKyaEdsyooTmS0zGv1U9JuZ8tSoPMx7bMg5rOh0HhVdtJOovtfqTiqdGQ+D0zNk
&gt;
&gt; 
Ej8kAuqlSzuHV+zTe8VeYeBIoNuEvB2dTlxzalQQju2CuQ1iqViuw8wtJtJIUsA9YY7eGcdJ8Esj5
&gt;
&gt; 
Yhyrs72Iwq4/LKGASaf8WI8Qk62H/H3EByFN+eTZxFm9fUAb/S3z0DbBKaEWIleeT5RhOfdhcbSco
&gt;
&gt; 
765NPrtU9TQJHSAbnZeMKfsgD22RDB/K4TjI7W/qZ4I/0O+weUEosfbhlKtncOB6PiIcCeWZVyMlz
&gt;
&gt; 
DNPQYBgTE7hUADDGu7PBgdSYxPLCZ3Qqhsg4NDZhX6KqEynMF0277HpBCYJOwTR/iCM7XhVzhp+0I
&gt;
&gt; 
vW/xx0zoPUKTqMvQivqhc1wGJ56CNKqTWfp7CxMv9OKm9d3Nl9VvvTcdP2XPGKLXpuajq7FXRqmwv
&gt; 2tsUrXagsSmRzCQrekXddfPPwozRTgDiH0gX0bFHag2JNaA==
&gt; X-HAS-ATTACH: no
&gt; X-QQ-BUSINESS-ORIGIN: 2
&gt; X-Originating-IP: 58.213.71.137
&gt; In-Reply-To: <[email protected]&amp;gt;
&gt; References: <[email protected]&amp;gt;
&gt; X-QQ-STYLE:
&gt; X-QQ-mid: webmail701t1600050643t2037358
&gt; From: "=?ISO-8859-1?B?eW9uZ3Fpbmc=?=" <[email protected]&amp;gt;
&gt; To:
&gt; 
"=?ISO-8859-1?B?ZGV2LXNjLjE2MDAwNTA1ODkubmVqbWVpcGRnYW1wZ2FqbW5pZ24tNTk3MzY1NTgxPXFxLmNvbQ==?="
&gt; <dev-sc.1600050589.nejmeipdgampgajmnign-597365581=
&gt; [email protected]&amp;gt;
&gt; Subject: Re:confirm subscribe to [email protected]
&gt; Mime-Version: 1.0
&gt; Content-Type: multipart/alternative;
&gt; boundary="----=_NextPart_5F5ED5D3_10876F28_16C1B710"
&gt; Content-Transfer-Encoding: 8Bit
&gt; Date: Mon, 14 Sep 2020 10:30:43 +0800
&gt; X-Priority: 3
&gt; Message-ID: <[email protected]&amp;gt;
&gt; X-QQ-MIME: TCMime 1.0 by Tencent
&gt; X-Mailer: QQMail 2.x
&gt; X-QQ-Mailer: QQMail 2.x
&gt; X-QQ-ReplyHash: 291485276
&gt; X-QQ-SENDSIZE: 520
&gt; Received: from qq.com (unknown [127.0.0.1])
&gt; by smtp.qq.com (ESMTP) with SMTP
&gt; id ; Mon, 14 Sep 2020 10:30:44 +0800 (CST)
&gt; Feedback-ID: webmail:qq.com:bgforeign:bgforeign11
&gt; X-QQ-Bgrelay: 1

Reply via email to