You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hop.apache.org by ha...@apache.org on 2022/01/06 18:03:49 UTC
[hop] branch master updated (93aa996 -> 0f645ec)
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(-)