Hi everyone, I have a basic question regarding scheduling of batch programs. Let's take the following graph:
-> Group Combine -> ... / Source ----> Group Combine -> ... \ -> Map -> ... So, a source and followed by three operators with ship strategy "Forward" and exchange mode "pipelined". The three flows are later joined again, so that this results in a single job. When the job is started, first, only one of the operators immediately receive the input read by the source and can therefore run concurrently with the source. Once the source is finished, the other two operators are scheduled. Two questions about this: 1) Why doesn't the source forward the records to all three operators while still running? 2) How does the jobmanager decide, which of the three operators receivese the pipelined data first? Cheers and Thanks, Konstantin -- Konstantin Knauf * konstantin.kn...@tngtech.com * +49-174-3413182 TNG Technology Consulting GmbH, Betastr. 13a, 85774 Unterföhring Geschäftsführer: Henrik Klagges, Christoph Stock, Dr. Robert Dahlke Sitz: Unterföhring * Amtsgericht München * HRB 135082
signature.asc
Description: OpenPGP digital signature