[2/2] beam git commit: This closes #3840

This closes #3840 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50532f0a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/50532f0a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/50532f0a Branch:

[1/2] beam git commit: [BEAM-2859] Fixed processing timers not being properly fired when watermark stays put by tweaking the way spark-runner was delivering timers to reduceFnRunner in SparkGroupAlsoB

Repository: beam Updated Branches: refs/heads/master 8d71ebf82 -> 50532f0a9 [BEAM-2859] Fixed processing timers not being properly fired when watermark stays put by tweaking the way spark-runner was delivering timers to reduceFnRunner in SparkGroupAlsoByWindowViaWindowSet Project:

[1/2] beam git commit: [BEAM-2825] Refactored SparkGroupAlsoByWindowViaWindowSet to improve readability.

Repository: beam Updated Branches: refs/heads/master a481d5611 -> f7d4583bd [BEAM-2825] Refactored SparkGroupAlsoByWindowViaWindowSet to improve readability. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c8b99ba3 Tree:

[2/2] beam git commit: This closes #3793

This closes #3793 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f7d4583b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f7d4583b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f7d4583b Branch:

[2/2] beam git commit: This closes #3749

This closes #3749 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a481d561 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a481d561 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a481d561 Branch:

[1/2] beam git commit: [BEAM-2669] Fixed Kryo serialization exception when dstream is cached (by using coders and moving to bytes before attempting to serialise an RDD as part of caching it).

Repository: beam Updated Branches: refs/heads/master 80aebd902 -> a481d5611 [BEAM-2669] Fixed Kryo serialization exception when dstream is cached (by using coders and moving to bytes before attempting to serialise an RDD as part of caching it). Project:

[2/2] beam git commit: This closes #3738

This closes #3738 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5181e619 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5181e619 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5181e619 Branch:

[1/2] beam git commit: [BEAM-2671] Implemented an InputDStream that syncs up with the watermark values, this should help with streaming tests in spark-runner.

Repository: beam Updated Branches: refs/heads/master c4517d04c -> 5181e619f [BEAM-2671] Implemented an InputDStream that syncs up with the watermark values, this should help with streaming tests in spark-runner. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #2854

This closes #2854 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e10fbdaa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e10fbdaa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e10fbdaa Branch:

[2/2] beam git commit: This closes #2733

This closes #2733 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/535761a7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/535761a7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/535761a7 Branch:

[1/2] beam git commit: [BEAM-2074, BEAM-2073] Fixed SourceDStream's rate control usage.

Repository: beam Updated Branches: refs/heads/master 254470e62 -> 535761a74 [BEAM-2074,BEAM-2073] Fixed SourceDStream's rate control usage. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fcb61ae6 Tree:

[2/2] beam git commit: This closes #2698

This closes #2698 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/254470e6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/254470e6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/254470e6 Branch:

[2/2] beam git commit: This closes #2403

This closes #2403 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/646cbdb7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/646cbdb7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/646cbdb7 Branch:

[1/2] beam git commit: [BEAM-1777] In certain circumstances PipelineEnforcement shades pipeline's exceptions.

Repository: beam Updated Branches: refs/heads/master 6df661b0e -> 646cbdb70 [BEAM-1777] In certain circumstances PipelineEnforcement shades pipeline's exceptions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d96a95c5

[2/2] beam git commit: This closes #2073

This closes #2073 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fe1d4124 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fe1d4124 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fe1d4124 Branch:

[1/2] beam git commit: [BEAM-1048] Added a read duration metric to SparkUnboundedSource.

Repository: beam Updated Branches: refs/heads/master ea33e3373 -> fe1d4124e [BEAM-1048] Added a read duration metric to SparkUnboundedSource. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/38e00f3f Tree:

[1/2] beam git commit: Added a specific signature so that Kryo doesn't have to look for it using reflective exploration.

Repository: beam Updated Branches: refs/heads/master 2a40534e8 -> 22d368b40 Added a specific signature so that Kryo doesn't have to look for it using reflective exploration. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #2356

This closes #2356 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2a40534e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2a40534e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2a40534e Branch:

[1/2] beam git commit: Extracted captures to static classes to prevent them from capturing the scope.

Repository: beam Updated Branches: refs/heads/master 769398e40 -> 2a40534e8 Extracted captures to static classes to prevent them from capturing the scope. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3876f83a Tree:

[1/2] beam git commit: [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline

Repository: beam Updated Branches: refs/heads/master d16715309 -> b6ca062fc [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/874c8d0d Tree:

[2/2] beam git commit: This closes #2171

This closes #2171 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b6ca062f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b6ca062f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b6ca062f Branch:

[2/2] beam git commit: This closes #2161

This closes #2161 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59451bca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59451bca Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/59451bca Branch:

[1/2] beam git commit: [BEAM-1625] BoundedDataset action() does not materialize RDD

Repository: beam Updated Branches: refs/heads/master 11a381b23 -> 59451bca6 [BEAM-1625] BoundedDataset action() does not materialize RDD Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4febd954 Tree:

[2/2] beam git commit: This closes #2083

This closes #2083 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3082178b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3082178b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3082178b Branch:

[1/2] beam git commit: Remove periods from step name in SparkBeamMetric to avoid inconsistent hierarchies in Graphite metric sink

Repository: beam Updated Branches: refs/heads/master 4bba380cb -> 3082178b3 Remove periods from step name in SparkBeamMetric to avoid inconsistent hierarchies in Graphite metric sink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: This closes #2089

This closes #2089 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4bba380c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4bba380c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4bba380c Branch:

[2/3] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/1a607ad8 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/1a607ad8 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/1a607ad8

[3/3] beam-site git commit: This closes #162

This closes #162 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/408f290e Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/408f290e Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/408f290e

[2/2] beam git commit: This closes #1706

This closes #1706 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f03f6ac1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f03f6ac1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f03f6ac1 Branch:

[1/2] beam git commit: [BEAM-1205] Auto set "enableAbandonedNodeEnforcement" in TestPipeline

Repository: beam Updated Branches: refs/heads/master 5fe78440b -> f03f6ac19 [BEAM-1205] Auto set "enableAbandonedNodeEnforcement" in TestPipeline Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50daea28 Tree:

[2/2] beam git commit: This closes #1991

This closes #1991 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4db4fb2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4db4fb2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4db4fb2 Branch:

[2/2] beam git commit: This closes #1986

This closes #1986 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4beed50f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4beed50f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4beed50f Branch:

[1/2] beam git commit: Fixed javadoc comment in ResumeFromCheckpointStreamingTest.

Repository: beam Updated Branches: refs/heads/master 93ae666be -> 4beed50f2 Fixed javadoc comment in ResumeFromCheckpointStreamingTest. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2f63b1f6 Tree:

[1/2] beam git commit: [BEAM-882, BEAM-883, BEAM-878] Simplified API surface verifications.

Repository: beam Updated Branches: refs/heads/master e21f9ae86 -> 6b31c14fa [BEAM-882,BEAM-883,BEAM-878] Simplified API surface verifications. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cde550fe Tree:

[2/2] beam git commit: This closes #1921

This closes #1921 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c442ef81 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c442ef81 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c442ef81 Branch:

[1/2] beam git commit: [BEAM-1304] Checking for nullity before trying to obtain an aggregator's value.

Repository: beam Updated Branches: refs/heads/master e5afbb27f -> c442ef81a [BEAM-1304] Checking for nullity before trying to obtain an aggregator's value. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/882c654b Tree: