beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amits...@apache.org
Subject [2/2] incubator-beam git commit: This closes #1364
Date Wed, 16 Nov 2016 00:01:44 GMT
This closes #1364


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

Branch: refs/heads/master
Commit: dbbd5e44800586c3f1a2efc58b91d79126c843d3
Parents: 2011102 dd740ee
Author: Sela <ansela@paypal.com>
Authored: Wed Nov 16 01:51:51 2016 +0200
Committer: Sela <ansela@paypal.com>
Committed: Wed Nov 16 01:51:51 2016 +0200

----------------------------------------------------------------------
 .../runners/spark/ProvidedSparkContextTest.java |  2 -
 .../metrics/sink/NamedAggregatorsTest.java      |  4 +-
 .../beam/runners/spark/io/AvroPipelineTest.java |  5 +--
 .../beam/runners/spark/io/NumShardsTest.java    |  5 +--
 .../io/hadoop/HadoopFileFormatPipelineTest.java |  5 +--
 .../spark/translation/SideEffectsTest.java      | 34 ++++++---------
 .../streaming/EmptyStreamAssertionTest.java     |  5 ++-
 .../streaming/FlattenStreamingTest.java         |  5 ++-
 .../streaming/KafkaStreamingTest.java           |  5 ++-
 .../ResumeFromCheckpointStreamingTest.java      |  5 ++-
 .../streaming/SimpleStreamingWordCountTest.java |  5 ++-
 .../utils/SparkTestPipelineOptions.java         | 42 +++++++++++++++++++
 .../SparkTestPipelineOptionsForStreaming.java   | 44 ++++++++++++++++++++
 .../streaming/utils/TestPipelineOptions.java    | 25 -----------
 .../utils/TestPipelineOptionsForStreaming.java  | 44 --------------------
 15 files changed, 121 insertions(+), 114 deletions(-)
----------------------------------------------------------------------



Mime
View raw message