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

Posted to commits@beam.apache.org by mx...@apache.org on 2019/12/18 13:59:28 UTC

[beam] branch master updated (0bcff1a -> 307dab2)

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 0bcff1a  Merge pull request #10175 from davidcavazos/max-code
     add c8d4bc0  Add FlinkMiniClusterEntryPoint for testing the uber jar submission
     add fddd976  [BEAM-8512] Add integration tests for flink_runner.py.
     add 719d9b1  Build mini cluster jar excluding unwanted classes.
     add fc62b03  Rename to testFlinkUberJarPyX.Y
     add bde32a4  Increase timeout on beam_PostCommit_PortableJar_Flink.
     add 307dab2  Merge pull request #10284: [BEAM-8512] Add integration tests for flink_runner.py

No new revisions were added by this update.

Summary of changes:
 .../job_PostCommit_PortableJar_Flink.groovy        |  2 +-
 runners/flink/flink_runner.gradle                  |  2 +
 runners/flink/job-server/flink_job_server.gradle   | 84 ++++++++++++++++----
 ...test_pipeline_jar.sh => test_flink_uber_jar.sh} | 49 ++++++++----
 .../runners/flink/FlinkMiniClusterEntryPoint.java  | 91 ++++++++++++++++++++++
 .../portability/flink_uber_jar_job_server.py       |  6 +-
 6 files changed, 201 insertions(+), 33 deletions(-)
 copy runners/flink/job-server/{test_pipeline_jar.sh => test_flink_uber_jar.sh} (72%)
 create mode 100644 runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkMiniClusterEntryPoint.java