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: refs/heads/maste
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: http://gi
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: ht
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: refs/heads/maste
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: refs/heads/maste
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: http://git-wip-us.apache.org/repos/as
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: refs/heads/maste
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: http://git-wip
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: refs/heads/maste
Repository: beam
Updated Branches:
refs/heads/master d96fd173c -> e10fbdaa2
[BEAM-2095] Made SourceRDD hasNext idempotent
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/81b89acb
Tree: http://git-wip-us.apache.org/repos/asf/
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: refs/heads/maste
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: http://git-wip-us.apa
Repository: beam
Updated Branches:
refs/heads/master b414f8de9 -> 254470e62
[BEAM-2072] Fixed MicrobatchSource.reader stops reading after reaching
maxNumRecords for the first time.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/c
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: refs/heads/maste
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: refs/heads/maste
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
Tre
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: refs/heads/maste
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: http://git-wip-us.a
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: http://git-wip-us.apache.org/repos/asf/beam/commit/1
This closes #2357
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/22d368b4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/22d368b4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/22d368b4
Branch: refs/heads/maste
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: refs/heads/maste
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: http:/
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: http://g
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: refs/heads/maste
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: refs/heads/maste
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: http://git-wip-us.apache
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: refs/heads/maste
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: http://git-wip-us.apache.org/repos/asf/beam
Repository: beam
Updated Branches:
refs/heads/master 38a01e9cf -> 4bba380cb
Updated TestPipeline's javadoc.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/acc10130
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/acc1
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: refs/heads/maste
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
Bra
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
Branc
Repository: beam-site
Updated Branches:
refs/heads/asf-site 3fd0ed617 -> 408f290eb
Adding testing related info: TestPipeline, API surface.
Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/3c0c5322
Tree: http://git-w
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: refs/heads/maste
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: http://git-wip-
Repository: beam
Updated Branches:
refs/heads/master 4beed50f2 -> d4db4fb2c
[BEAM-1470] A quite logger for testing.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8014a6e1
Tree: http://git-wip-us.apache.org/repos/asf/beam/t
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: refs/heads/maste
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: refs/heads/maste
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: http://git-wip-us.apache.
This closes #1888
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6b31c14f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6b31c14f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6b31c14f
Branch: refs/heads/maste
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: http://git-wip-us.
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: refs/heads/maste
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: http:
43 matches
Mail list logo