#2798: [Fix-9868] A task flow definition isolates the runs of different execution strategies by version numbers. (#9869)

* The thread cache task flow definition should get the latest version. * Coverage on New Code * Coverage on New Code * Coverage on New Code * use an existing method. * Increase unit test coverage. * Task flow definitions enforce policy isolation.
3 years ago · 70e3be8b4c
2 changed files with 141 additions and 36 deletions
--- a/commit.ref
+++ b/commit.ref
@ -1 +1 @@
-Subproject commit 778018dcfb21420516b9194f77c199aaf4b56768
+Subproject commit fb0f96ed946c89323ba347eb9d538a22b9be6e73
--- a/commit.yml
+++ b/commit.yml
@ -2,40 +2,145 @@
 branches: {
  }
 fileChange:
-  /dolphinscheduler-worker:
-    newFile: !uuid '8d4a286ba7cbad663f41fe178c20cb5abcba45d5'
-    oldFile: !uuid 'c27bf1da1c193462a13824202b1a4eb327add687'
-  /dolphinscheduler-worker/src:
-    newFile: !uuid '2fb7f500cbc2b9695d29cb077f844e22f4b98682'
-    oldFile: !uuid '0a36f3ce4e16017464a39c0066cb7b249de723ee'
-  /dolphinscheduler-worker/src/main:
-    newFile: !uuid 'afc69b12f110aa66b79b16190a96ec6e688d5bcd'
-    oldFile: !uuid 'f27f407fad491c311ec0d085be261b84cf0809a2'
-  /dolphinscheduler-worker/src/main/java:
-    newFile: !uuid '80ce82d40f38ed9b9b5ac3e87c648a15b9408dc9'
-    oldFile: !uuid 'eed3eb825e8250580af954f7936443aea2887c79'
-  /dolphinscheduler-worker/src/main/java/org:
-    newFile: !uuid '5b8108ef146c5ce98775b5e10f0b69204b0c397e'
-    oldFile: !uuid '9258140e888b4b9669afc7186c5989e8e0150431'
-  /dolphinscheduler-worker/src/main/java/org/apache:
-    newFile: !uuid 'b18e9ded7abbc6eec911897a3d5525421b598713'
-    oldFile: !uuid '58cdad64644eab1ee467b6dc492a15f752f8f804'
-  /dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler:
-    newFile: !uuid 'd10f87dc0c0282a83ca450424728dccd281d0ffc'
-    oldFile: !uuid '33de8cd8a33de732a612c742e265aa207be4d33a'
-  /dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server:
-    newFile: !uuid '48bb4e97fa70cbcf32f7a714440d52196dd37ed1'
-    oldFile: !uuid '7b30d15b0f4894893d7c6e5340f4f4eb13ce044e'
-  /dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker:
-    newFile: !uuid '3acfd55a47ba01932ac91e25518f5689309cec34'
-    oldFile: !uuid '4d3ec14620c934cf4cff10458856ca81d4ba34b7'
-  /dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor:
-    newFile: !uuid 'cf2953bec652e85906f04969c6471ec651e9e1f7'
-    oldFile: !uuid '3e7cc30723961a9a42f631723fa3b2a75c5b6338'
-  /dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskCallbackService.java:
-    newFile: !uuid '3641de8453b108907b9b61e57b382b0e5a8c3226'
-    oldFile: !uuid 'c3eb07b2ad17e1a506d707a1b63c35b8226fd518'
-gitCommitId: !uuid '778018dcfb21420516b9194f77c199aaf4b56768'
+  /dolphinscheduler-dao:
+    newFile: !uuid 'aa833e9ba377e4fa75c65486e7050941e91ca377'
+    oldFile: !uuid '40b1976424bd23c37865d7250ae0a24ef6d3aed1'
+  /dolphinscheduler-dao/src:
+    newFile: !uuid '8dbbfb421e8bb5d91babcd108a36a32fbfe0e0ff'
+    oldFile: !uuid 'fdd4f19e5aebc8643403b2fb224e2c04b3532f04'
+  /dolphinscheduler-dao/src/main:
+    newFile: !uuid 'e91c2080ecee9999fcd5b5ce1030647f9d99c290'
+    oldFile: !uuid 'cdb634bd5b68e2e468f74051e743810f544e853f'
+  /dolphinscheduler-dao/src/main/java:
+    newFile: !uuid '2a50ef9697476098f0d3f8ffeaec5f3c1d896772'
+    oldFile: !uuid 'c99c39d0787f30883e5858eaa91ab194696eaab7'
+  /dolphinscheduler-dao/src/main/java/org:
+    newFile: !uuid '823059b5c6368f1d6e4cb3ebd397bb5b81dd5fe4'
+    oldFile: !uuid '9ad4dc4275959b75f0d1a9d523fdb98c5ecc3cdc'
+  /dolphinscheduler-dao/src/main/java/org/apache:
+    newFile: !uuid '4ce2cbcb5cfd95410a2e7137c20ec742bd28ecc6'
+    oldFile: !uuid 'a61568e3ca3d222067fb6fd348e85a73d4ac69df'
+  /dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler:
+    newFile: !uuid '1e362fbe2906119177db3b04b9c4aa76cf398fcb'
+    oldFile: !uuid '4a57ce2676cac3ff67b52af3e98a3c99cba14e78'
+  /dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao:
+    newFile: !uuid 'ed263e0961a7dfd9d4bb32146adeb0c349330f21'
+    oldFile: !uuid '6c0fc33efa8536142ac9822782668514acb47e6d'
+  /dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper:
+    newFile: !uuid '6d58d8433160abf3a90643d219c8496d6c16c45f'
+    oldFile: !uuid 'c0c350aa2d99b07e599e4ada4951f174924516b1'
+  /dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.java:
+    newFile: !uuid '8c0abf3dce01b05a64edace1a4c626f1200428df'
+    oldFile: !uuid '1a639df8b47be8cf1b55ef7a1ee5347e012f9e67'
+  /dolphinscheduler-dao/src/main/resources:
+    newFile: !uuid '101fd57878948fd5db3a2ac8fdcf7ee8b0d8407e'
+    oldFile: !uuid 'df843fc15e557396d7af986bcad6a5f1916c995f'
+  /dolphinscheduler-dao/src/main/resources/org:
+    newFile: !uuid '85fffce1bf5deea5799d64eead50893011a20cdd'
+    oldFile: !uuid 'c7e1a588495b07164280b5985534af9f0f289cb2'
+  /dolphinscheduler-dao/src/main/resources/org/apache:
+    newFile: !uuid '6f4e478a9fef35ec9b50bfdc3a06441bcdc52698'
+    oldFile: !uuid 'ff73b69610ff0bf921fe6e39d14dc725b566c7bf'
+  /dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler:
+    newFile: !uuid '44fd56a47a64d2e4d3dc53f801d113e35337280f'
+    oldFile: !uuid '392e40dd33e7593d4a7e0150601a2b44d187988a'
+  /dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao:
+    newFile: !uuid 'ad74f75916c3566484375325653bf758820ce025'
+    oldFile: !uuid '6ba005499915debdadd3fdb05c68899d4f738fa0'
+  /dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper:
+    newFile: !uuid 'fb2de4a9ce303bb3fc837aa117007e05cf8b6708'
+    oldFile: !uuid 'f09503b5bbb5e6ccbeddf37f3b37f26c7f5b05e8'
+  /dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/ProcessInstanceMapper.xml:
+    newFile: !uuid 'd77e3cc4d8164dbbf59fc724ca6debe6f482a4db'
+    oldFile: !uuid '2e49ce9b5b300e06642f01ad01470beb2fab1a7e'
+  /dolphinscheduler-master:
+    newFile: !uuid 'fe99f5b91db82772ee8e2e215bc7203060d5480d'
+    oldFile: !uuid '0e2656e9c6db4ed892effc4d42e805890c3cf82f'
+  /dolphinscheduler-master/src:
+    newFile: !uuid '01f85d87895ba30c92d66830514285f2f28a1276'
+    oldFile: !uuid '0d31c042b6f368259ba1526371ed30df85d90129'
+  /dolphinscheduler-master/src/main:
+    newFile: !uuid '4ff8a7a28930d14c0f6e634772599fa805b9230f'
+    oldFile: !uuid '70c4e2adedd0f35133cd5e4c0278e63eeb077157'
+  /dolphinscheduler-master/src/main/java:
+    newFile: !uuid 'dd1f573cbf8fe396bbdac831ea61189cec2055ce'
+    oldFile: !uuid 'aa9bb3026bbfe957c6270907d319ff7bcfc0ef2b'
+  /dolphinscheduler-master/src/main/java/org:
+    newFile: !uuid '42e1cb61c6ae9499f77f6649f318fdeefe7b5820'
+    oldFile: !uuid 'f96232ed9119c637bca017f07a1198fd80b9dc78'
+  /dolphinscheduler-master/src/main/java/org/apache:
+    newFile: !uuid 'fcfb25b6302441e0d894164a44b042d32e93092e'
+    oldFile: !uuid 'eb07685dd6d6c6e72302be1a79c69fba9ef96b14'
+  /dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler:
+    newFile: !uuid 'c2f54819f8792c1e064a79b35c2ead8f4331fffb'
+    oldFile: !uuid 'fb85b484997f00824c91dbbd10cd18b134fcaec9'
+  /dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server:
+    newFile: !uuid 'f440f316bf1d683482a170ff6b1cecdbd08efc20'
+    oldFile: !uuid '7fa9d650f7aed42083fe39587fbc4daa0a0b0bd1'
+  /dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master:
+    newFile: !uuid 'f80b1b91ddf60e71973d3324b927d35d7fab2cb6'
+    oldFile: !uuid '69c78582df5eb3f4ffe215341e5cc9fded568dcb'
+  /dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner:
+    newFile: !uuid 'cff9a3e995058d48186d0e2dabc727366ac6e91b'
+    oldFile: !uuid '46d107b7cca76d9ab7ed3a27786d1abfbb239f8e'
+  /dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java:
+    newFile: !uuid 'b7af67e675e5ca92c958bdba1f89b2ba751ab581'
+    oldFile: !uuid '1db5d81b6d9049573697bc8b9c6960910b0ababd'
+  /dolphinscheduler-service:
+    newFile: !uuid 'e8091d1dcc61d3a118a6fcbc11bdfc81451e1059'
+    oldFile: !uuid 'f3a6b8bb714602d37d660ebf0a634bafd2db9669'
+  /dolphinscheduler-service/src:
+    newFile: !uuid '919f234d9c285372e61dfac150ae9ff84193df85'
+    oldFile: !uuid 'b37940f06e1701d12b2a49a0def181fef5545279'
+  /dolphinscheduler-service/src/main:
+    newFile: !uuid '01612b23cd07a813f769d71f62592a3607533c24'
+    oldFile: !uuid 'ae29f013f7610a3bbedd06b6638fb1d1aaa640b6'
+  /dolphinscheduler-service/src/main/java:
+    newFile: !uuid 'f80f7c5ede338ad626a880c26efcd6bf3cb4cfb0'
+    oldFile: !uuid 'd2f5abee28bb12ade3a99ce17431beea8b39b029'
+  /dolphinscheduler-service/src/main/java/org:
+    newFile: !uuid '786943603a0a5a49a83ab62d769891a00a9450b8'
+    oldFile: !uuid 'b66a2aef40c4fb3e051effde6d3d0a8342545da3'
+  /dolphinscheduler-service/src/main/java/org/apache:
+    newFile: !uuid '56351ba679573e4ae5842003b12556482cbb5ed0'
+    oldFile: !uuid '1a3c39ad0a59fd76645da61e25e565240257da0f'
+  /dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler:
+    newFile: !uuid 'e47e0806a8c90b388231f03e913ced49e605cd17'
+    oldFile: !uuid 'd3338c377d094d34393f7c2a66af6f117d5567aa'
+  /dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service:
+    newFile: !uuid '896a5ca2c9f7ae7bc43a891426cfe854ac19c156'
+    oldFile: !uuid '7f6a1f1da8c5ad37c362df733be6a7aab07b74dc'
+  /dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process:
+    newFile: !uuid '5551a25ace9f9bf71f7c154938d7f5d57f4ba3df'
+    oldFile: !uuid '7f017629915ffac8e7a99809eb836b0abf826920'
+  /dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessServiceImpl.java:
+    newFile: !uuid '53c20a5ae83f737deca62065c14e58572bb6f6c6'
+    oldFile: !uuid '58183f2c88fc87dd36fbfef2affa60035409d294'
+  /dolphinscheduler-service/src/test:
+    newFile: !uuid 'afa417b0cd60c9f88b76ab182231677684a7d823'
+    oldFile: !uuid '434fa6c4f92232ee8b180ff4687d0ce2575b14b0'
+  /dolphinscheduler-service/src/test/java:
+    newFile: !uuid '70fa3ce4ab1919ee0c78e7fafef32318cddb4f4a'
+    oldFile: !uuid '49c3bae33cd90f19628eccb18b2625d65531e521'
+  /dolphinscheduler-service/src/test/java/org:
+    newFile: !uuid '5f0953d4e9cde52914b366d3f83fe51e280494a7'
+    oldFile: !uuid '76264999a2fe849e8f818f3fc67d92297a758bee'
+  /dolphinscheduler-service/src/test/java/org/apache:
+    newFile: !uuid '73d468d191f4189518af09760ee1ba14ee01ed05'
+    oldFile: !uuid '0530d7406fccff31f385eff3e5263dae0d772879'
+  /dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler:
+    newFile: !uuid '825670584fa77db969a337f990c0615219f6df67'
+    oldFile: !uuid '79e0d26ebb94a8bfc27ab86c56bcf4c9be6eb9d3'
+  /dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service:
+    newFile: !uuid 'd0147f3c743b23d2517a1ac00bf67029dd25fe40'
+    oldFile: !uuid 'ce78807dd9d4a94043497136952c8b3a82724f83'
+  /dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process:
+    newFile: !uuid '665262a0f68437e1bfb57be484d2e13c087cb72b'
+    oldFile: !uuid 'd8cab170e15c09cdd0a97aefffb843ea81965f6c'
+  /dolphinscheduler-service/src/test/java/org/apache/dolphinscheduler/service/process/ProcessServiceTest.java:
+    newFile: !uuid '47bdca17d14e6a6e17e0ba3e79fa6a5548d8cf49'
+    oldFile: !uuid '22575681e15dd2e190b7e2b2b83d50e8a3b6ffba'
+gitCommitId: !uuid 'fb0f96ed946c89323ba347eb9d538a22b9be6e73'
 renames: {
  }
-revisionId: 2797
+revisionId: 2798