You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by th...@apache.org on 2016/11/07 19:59:28 UTC

[38/50] incubator-beam git commit: This closes #1272

This closes #1272


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/14e093a0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/14e093a0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/14e093a0

Branch: refs/heads/apex-runner
Commit: 14e093a0a574c8c3920a83c38e411a06b29bf44b
Parents: 46fbfe0 90a75d1
Author: Sela <an...@paypal.com>
Authored: Sat Nov 5 00:02:22 2016 +0200
Committer: Sela <an...@paypal.com>
Committed: Sat Nov 5 00:02:22 2016 +0200

----------------------------------------------------------------------
 .../runners/spark/SparkPipelineOptions.java     |  3 +--
 .../SparkRunnerStreamingContextFactory.java     | 23 +++++---------------
 .../streaming/EmptyStreamAssertionTest.java     |  3 +--
 .../streaming/FlattenStreamingTest.java         |  6 ++---
 .../streaming/KafkaStreamingTest.java           |  6 ++---
 .../ResumeFromCheckpointStreamingTest.java      |  3 +--
 .../streaming/SimpleStreamingWordCountTest.java |  3 +--
 .../utils/TestOptionsForStreaming.java          | 12 +++++-----
 8 files changed, 19 insertions(+), 40 deletions(-)
----------------------------------------------------------------------