This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6126169 Increment the Dataflow container version
new dfd16f2 [BEAM-981] Add parameter allowing adding jars to spark context
new 57310a6 Post code review amendments and refactor
new cd7ef91 Remove @JsonIgnore to allow setting filesToStage from command
line
new 6bf325e Post code review amendments
new 9ad40dc [BEAM-981] Add parameter allowing adding jars to spark context
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../core/construction/PipelineResources.java | 57 ++++++++++++++++
.../core/construction/PipelineResourcesTest.java | 76 ++++++++++++++++++++++
.../beam/runners/flink/FlinkPipelineOptions.java | 1 -
.../org/apache/beam/runners/flink/FlinkRunner.java | 36 +---------
.../beam/runners/dataflow/DataflowRunner.java | 41 ++----------
.../options/DataflowPipelineWorkerPoolOptions.java | 1 -
.../beam/runners/dataflow/DataflowRunnerTest.java | 36 ----------
.../beam/runners/spark/SparkContextOptions.java | 2 +-
.../beam/runners/spark/SparkPipelineOptions.java | 14 +++-
.../org/apache/beam/runners/spark/SparkRunner.java | 13 ++++
.../spark/translation/SparkContextFactory.java | 5 ++
11 files changed, 170 insertions(+), 112 deletions(-)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineResources.java
create mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/PipelineResourcesTest.java
--
To stop receiving notification emails like this one, please contact
['"commits@beam.apache.org" <commits@beam.apache.org>'].
