scheduling icon indicating copy to clipboard operation
scheduling copied to clipboard

Bad management of PA_TASK_REPLICATION in replicated tasks block

Open mbenguig opened this issue 8 years ago • 1 comments

In case of replicated tasks (e.g. 4), each task triggering a block of replicated tasks (e.g. 3), PA_TASK_REPLICATION indexes are not correctly managed.

[email protected];13:13:29] Split 1st-replication-level:3 [[email protected];13:13:29] Split 1st-replication-level:2 [[email protected];13:13:27] Split 1st-replication-level:1 [[email protected];13:13:39] Process 1st-replication-level:1 2nd-replication-level:4 [[email protected];13:13:40] Process 1st-replication-level:0 2nd-replication-level:0 [[email protected];13:13:40] Process 1st-replication-level:1 2nd-replication-level:5 [[email protected];13:13:27] Split 1st-replication-level:0 [[email protected];13:13:41] Process 1st-replication-level:0 2nd-replication-level:6 [[email protected];13:13:41] Process 1st-replication-level:3 2nd-replication-level:3 [[email protected];13:13:42] Process 1st-replication-level:0 2nd-replication-level:7 [[email protected];13:13:42] Process 1st-replication-level:3 2nd-replication-level:8 [[email protected];13:13:42] Process 1st-replication-level:2 2nd-replication-level:10 [[email protected];13:13:42] Process 1st-replication-level:2 2nd-replication-level:11 [[email protected];13:13:43] Process 1st-replication-level:3 2nd-replication-level:9 [[email protected];13:13:43] Process 1st-replication-level:2 2nd-replication-level:2 [[email protected];13:13:46] Merge 2nd-replication-level:1 [[email protected];13:13:46] Merge 2nd-replication-level:0 [[email protected];13:13:47] Merge 2nd-replication-level:2 [[email protected];13:13:47] Merge 2nd-replication-level:3

TEST_BUG.xml.txt

mbenguig avatar Jun 13 '17 11:06 mbenguig

Similar issue:

Screen-Shot-2019-03-14-at-14-31-07

Output:

[[email protected];15:34:04] BEGIN Split1 
[[email protected];15:34:04] result: [0:abc, 1:def] 
[[email protected];15:34:04] END Split1 

[[email protected];15:34:07] BEGIN Process1 
[[email protected];15:34:07] replication: 0 
[[email protected];15:34:07] input: abc 
[[email protected];15:34:07] result: ABC 
[[email protected];15:34:07] END Process1 

[[email protected];15:34:07] BEGIN Process1*1 
[[email protected];15:34:07] replication: 1 
[[email protected];15:34:07] input: def 
[[email protected];15:34:07] result: DEF 
[[email protected];15:34:07] END Process1*1 

[[email protected];15:34:09] BEGIN Split2 
[[email protected];15:34:09] result: [0:abc, 1:def] 
[[email protected];15:34:09] END Split2 

[[email protected];15:34:09] BEGIN Split2*1 
[[email protected];15:34:09] result: [0:abc, 1:def] 
[[email protected];15:34:09] END Split2*1 

[[email protected];15:34:13] BEGIN Process2 
[[email protected];15:34:13] replication: 0 
[[email protected];15:34:13] replication_1: 0 
[[email protected];15:34:13] replication 1 as reference 
[[email protected];15:34:13] input: abc 
[[email protected];15:34:13] result: ABC 
[[email protected];15:34:13] END Process2 

[[email protected];15:34:13] BEGIN Process2*2 
[[email protected];15:34:13] replication: 2 
[[email protected];15:34:13] replication_1: 0 
[[email protected];15:34:13] replication 1 as reference 
[[email protected];15:34:13] input: abc 
[[email protected];15:34:13] result: ABC 
[[email protected];15:34:13] END Process2*2 

[[email protected];15:34:13] BEGIN Process2*1 
[[email protected];15:34:13] replication: 1 
[[email protected];15:34:13] replication_1: 1 
[[email protected];15:34:13] replication 1 as reference 
[[email protected];15:34:13] input: def 
[[email protected];15:34:13] result: DEF 
[[email protected];15:34:13] END Process2*1 

[[email protected];15:34:14] BEGIN Process2*3 
[[email protected];15:34:14] replication: 3 
[[email protected];15:34:14] replication_1: 1 
[[email protected];15:34:14] replication 1 as reference 
[[email protected];15:34:14] input: def 
[[email protected];15:34:14] result: DEF 
[[email protected];15:34:14] END Process2*3 

[[email protected];15:34:16] BEGIN Merge2 
[[email protected];15:34:16] (input) results: [ABC, ABC] 
[[email protected];15:34:16] res: ABC 
[[email protected];15:34:16] res: ABC 
[[email protected];15:34:16] (output) result: [ABC, ABC] 
[[email protected];15:34:16] END Merge2 

[[email protected];15:34:16] BEGIN Merge2*1 
[[email protected];15:34:16] (input) results: [DEF, DEF] 
[[email protected];15:34:16] res: DEF 
[[email protected];15:34:16] res: DEF 
[[email protected];15:34:16] (output) result: [DEF, DEF] 
[[email protected];15:34:16] END Merge2*1 

[[email protected];15:34:17] BEGIN Merge1 
[[email protected];15:34:17] (input) results: [[ABC, ABC], [DEF, DEF]] 
[[email protected];15:34:17] END Merge1 

Illustration: Screen-Shot-2019-03-14-at-16-02-03

Workflow XML: test_replicate.xml.zip

andrewssobral avatar Mar 14 '19 15:03 andrewssobral