fix flakiness for side inputs and implement based on iasoon@ implementation

ray-project / ray_beam_runner

Ray-based Apache Beam runner

Apache License 2.0

42 stars 12 forks source link

fix flakiness for side inputs and implement based on iasoon@ implementation #44

Closed pabloem closed 2 years ago

pabloem commented 2 years ago

…ntation

pabloem commented 2 years ago

r: @iasoon - I based this on your previous implementation. I've ran all tests 10 times without any failures. I think we can review / merge this if it looks fine : )