...
draw.io Diagram | ||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|
Figure 2: The format of the state-based storage. The state header contains the version number and is written once per
logical input / output. Each buffer is prefixed with the channel id for restoring the original assignment to channels.
...
draw.io Diagram border true viewerToolbar true fitWindow false diagramDisplayName Violating ordering guarantees while rescaling of non-keyed data lbox true revision 3 diagramName rescale.drawio simpleViewer false width links auto tbstyle top diagramWidth 521 revision 3
Figure 3: Violating ordering guarantees while rescaling of non-keyed data. Split S1 is moved from source instance I to instance II.
If the original operators are
back-pressured, data from the new source instance can overtake the original data.
...