Commits

Commits on Aug 29, 2017

This closes apache#3780
aviemzur
committedAug 29, 2017

Commits on Aug 13, 2017

This closes apache/beam-site#287
aviemzur
committedAug 13, 2017
Update PMC

aviemzur
authored and
Zur, Aviem
committedAug 13, 2017

Commits on Jul 24, 2017

This closes apache#3286
aviemzur
committedJul 24, 2017

Commits on Jun 22, 2017

This closes apache#3343
aviemzur
committedJun 22, 2017
Move Spark runner streaming tests to post commit.
aviemzur
committedJun 22, 2017
[BEAM-2359] Fix watermark broadcasting to executors in Spark runner
aviemzur
committedJun 22, 2017

Commits on Jun 3, 2017

This closes apache#2917
aviemzur
committedJun 3, 2017

Commits on May 12, 2017

[BEAM-2279] Add HDFS support to Spark runner profiles in archetypes and examples

aviemzur
authored and
davorbonaci
committedMay 12, 2017
[BEAM-2277] Fix URI_SCHEME_PATTERN in FileSystems

aviemzur
authored and
dhalperi
committedMay 12, 2017

Commits on May 6, 2017

This closes apache#2649
aviemzur
committedMay 6, 2017
[BEAM-1672] Use Accumulable MetricsContainers in Flink runner.
aviemzur
committedMay 6, 2017
[BEAM-1672] Use Accumulable MetricsContainers in Spark runner.
aviemzur
committedMay 6, 2017
[BEAM-1672] Make MetricsContainers accumulable.
aviemzur
committedMay 6, 2017

Commits on May 4, 2017

Commits on May 2, 2017

[BEAM-2139] Disable SplittableDoFn ValidatesRunner tests for Streaming Flink Runner

aviemzur
authored and
lukecwik
committedMay 2, 2017

Commits on May 1, 2017

This closes apache#2797
aviemzur
committedMay 1, 2017
[BEAM-2129] Fix flaky KafkaIOTest#testUnboundedSourceMetrics
aviemzur
committedMay 1, 2017

Commits on Apr 29, 2017

This closes apache#2344
aviemzur
committedApr 29, 2017
[BEAM-1398] KafkaIO metrics.
aviemzur
committedApr 29, 2017
This closes apache#2730
aviemzur
committedApr 29, 2017
Fix broken build
aviemzur
committedApr 29, 2017

Commits on Apr 27, 2017

[BEAM-2029] NullPointerException when using multi output ParDo in Spark runner in streaming mode.

aviemzur
authored and
dhalperi
committedApr 27, 2017

Commits on Apr 26, 2017

This closes apache#2538
aviemzur
committedApr 26, 2017
[BEAM-1958] Standard IO Metrics in Java SDK
aviemzur
committedApr 26, 2017

Commits on Apr 13, 2017

This closes apache#2514
aviemzur
committedApr 13, 2017
[BEAM-1950] Add missing 'static' keyword to MicrobatchSource#initReaderCache
aviemzur
committedApr 13, 2017

Commits on Apr 9, 2017

This closes apache#2033
aviemzur
committedApr 9, 2017
[BEAM-1294] Long running UnboundedSource Readers
aviemzur
committedApr 9, 2017

Commits on Apr 1, 2017

This closes apache#2133
aviemzur
committedApr 1, 2017
[BEAM-1337] Infer state coders
aviemzur
committedApr 1, 2017

Commits on Mar 28, 2017

This closes apache#2345
aviemzur
committedMar 28, 2017