GitHub user kobisalant opened a pull request:
https://github.com/apache/incubator-beam/pull/1624
[BEAM-647] Fault-tolerant sideInputs via Broadcast variables
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
GitHub user kobisalant opened a pull request:
https://github.com/apache/incubator-beam/pull/1393
Beam-1001 "Add non blocking cancel() and waitUntilFinish() for Spark â¦
Be sure to do all of the following to help us incorporate your contribution
quickly and e