[GitHub] beam pull request #3840: [BEAM-2859] Fixed processing timers not being prope...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/3840 [BEAM-2859] Fixed processing timers not being properly fired Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue

[GitHub] beam pull request #3793: [BEAM-2825] Refactored SparkGroupAlsoByWindowViaWin...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/3793 [BEAM-2825] Refactored SparkGroupAlsoByWindowViaWindowSet to improve … …readability. Follow this checklist to help us incorporate your contribution quickly and easily

[GitHub] beam pull request #3738: [BEAM-2671] Fixing CreateStreamTest#testFirstElemen...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/3738 [BEAM-2671] Fixing CreateStreamTest#testFirstElementLate Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https

[GitHub] beam pull request #2854: [BEAM-2095] Made SourceRDD hasNext idempotent

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2854 [BEAM-2095] Made SourceRDD hasNext idempotent Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam pull request #2733: [BEAM-2074,BEAM-2073] Fixed SourceDStream's rate co...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2733 [BEAM-2074,BEAM-2073] Fixed SourceDStream's rate control usage. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] beam pull request #2698: [BEAM-2072] Fixed MicrobatchSource.reader stops rea...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2698 [BEAM-2072] Fixed MicrobatchSource.reader stops reading unexpectedly. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[GitHub] beam pull request #2403: [BEAM-1777] In certain circumstances PipelineEnforc...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2403 [BEAM-1777] In certain circumstances PipelineEnforcement shades exceptions. …ine's exceptions. Be sure to do all of the following to help us incorporate your contribution quickly

[GitHub] beam pull request #2357: Added a specific signature so that Kryo doesn't hav...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2357 Added a specific signature so that Kryo doesn't have to look for it u… …sing reflective exploration. Be sure to do all of the following to help us incorporate your contribution

[GitHub] beam pull request #2356: Extracted anonymous classes to prevent things from ...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2356 Extracted anonymous classes to prevent things from being captured inc… …identally. Be sure to do all of the following to help us incorporate your contribution quickly and easily

[GitHub] beam pull request #2355: Switched to using "destroy" instead of "unpersist" ...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2355 Switched to using "destroy" instead of "unpersist" for broadcasts. Be sure to do all of the following to help us incorporate your contribution quickly and easily: -

[GitHub] beam pull request #1695: [BEAM-1215] Added an in memory Graphite server that...

Github user staslev closed the pull request at: https://github.com/apache/beam/pull/1695 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] beam pull request #2089: [BEAM-1543] Updated TestPipeline's javadoc.

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2089 [BEAM-1543] Updated TestPipeline's javadoc. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam-site pull request #162: [BEAM-1499] Adding testing related info: TestPi...

GitHub user staslev opened a pull request: https://github.com/apache/beam-site/pull/162 [BEAM-1499] Adding testing related info: TestPipeline, API surface. You can merge this pull request into a Git repository by running: $ git pull https://github.com/staslev/beam-site adding

[GitHub] beam pull request #1921: [BEAM-1304] Checking for nullity before trying to o...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/1921 [BEAM-1304] Checking for nullity before trying to obtain an aggregator's value. Be sure to do all of the following to help us incorporate your contribution quickly and easily

[GitHub] beam pull request #1888: [BEAM-882,BEAM-883,BEAM-878] Simplified API surface...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/1888 [BEAM-882,BEAM-883,BEAM-878] Simplified API surface verifications (take 2) Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[GitHub] beam pull request #1780: [BEAM-882,BEAM-883,BEAM-878] Simplified the creatio...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/1780 [BEAM-882,BEAM-883,BEAM-878] Simplified the creation of new API surface tests. Be sure to do all of the following to help us incorporate your contribution quickly and easily

[GitHub] beam pull request #1723: [BEAM-1223] Introduced Sum,Min,Max#ofLongs()/ofDoub...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/1723 [BEAM-1223] Introduced Sum,Min,Max#ofLongs()/ofDoubles()/ofIntegers()… Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure