This is an automated email from the ASF dual-hosted git repository.
hansva pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hop.git.
from 93aa996 Merge pull request #1254 from bamaer/HOP-3562
new 932ad31 HOP-3599 : Improve documentation of the Apache Flink pipeline
configuration
new 85dd867 HOP-3600 : Beam Flink Run causes Hadoop classpath error
new 9de0eab HOP-3601 : The Flink pipeline run configuration always runs
embedded
new e4c58e8 HOP-3600 : Beam Flink Run causes Hadoop classpath error
HOP-3603 : Update the Beam flink runner to 1.13
new 882abc0 HOP-3599 : Improve documentation of the Apache Flink pipeline
configuration HOP-3600 : Beam Flink Run causes Hadoop classpath error HOP-3601
: The Flink pipeline run configuration always runs embedded HOP-3603 : Update
the Beam flink runner to 1.13
new 3d8f399 HOP-3599 : Improve documentation of the Apache Flink pipeline
configuration HOP-3600 : Beam Flink Run causes Hadoop classpath error HOP-3601
: The Flink pipeline run configuration always runs embedded HOP-3603 : Update
the Beam flink runner to 1.13
new d478475 HOP-3600 : Beam Flink Run causes Hadoop classpath error
new 0f645ec Merge pull request #1262 from mattcasters/master
The 3333 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:
assemblies/core/lib/pom.xml | 1 -
assemblies/plugins/engines/beam/pom.xml | 74 +++++++++---------
.../plugins/engines/beam/src/assembly/assembly.xml | 31 ++++----
assemblies/plugins/tech/aws/pom.xml | 4 +-
.../plugins/tech/google/src/assembly/assembly.xml | 1 -
assemblies/plugins/transforms/json/pom.xml | 6 +-
core/pom.xml | 6 +-
.../pipeline/beam/getting-started-with-beam.adoc | 19 ++++-
.../beam-flink-pipeline-engine.adoc | 72 +++++++++++++++++-
.../beam-spark-pipeline-engine.adoc | 18 ++++-
plugins/engines/beam/pom.xml | 44 ++++++-----
.../beam/core/transform/TransformTransform.java | 6 ++
.../flink/BeamFlinkPipelineRunConfiguration.java | 10 ++-
.../spark/BeamSparkPipelineRunConfiguration.java | 2 +
.../HopPipelineMetaToBeamPipelineConverter.java | 88 +++++++++++-----------
.../java/org/apache/hop/beam/run/MainBeam.java | 27 +++----
.../engines/spark/BeamSparkPipelineEngineTest.java | 3 +
...PipelineMetaPriorToExecutionExtensionPoint.java | 6 ++
plugins/tech/aws/pom.xml | 2 +-
plugins/transforms/json/pom.xml | 10 +--
pom.xml | 51 +++----------
21 files changed, 288 insertions(+), 193 deletions(-)
