You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2019/05/09 13:55:03 UTC
[beam] branch master updated (260677a -> e55ab73)
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 260677a Merge pull request #8528: [BEAM-7228] Add a Jenkins job running ValidatesRunner tests for Direct runner
add eb21fb8 [BEAM-7012] Support TestStream in portable Flink Runner
new e55ab73 Merge pull request #8411: [BEAM-7012] Support TestStream in portable Flink Runner
The 1 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/TestStreamTranslation.java | 2 +-
runners/flink/job-server/flink_job_server.gradle | 6 +++-
.../FlinkStreamingPortablePipelineTranslator.java | 42 ++++++++++++++++++++++
.../flink/FlinkStreamingTransformTranslators.java | 13 ++++++-
.../wrappers/streaming/io/TestStreamSource.java | 11 +++---
5 files changed, 66 insertions(+), 8 deletions(-)
[beam] 01/01: Merge pull request #8411: [BEAM-7012] Support
TestStream in portable Flink Runner
Posted by ie...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit e55ab73e11d43953d056c76a0efa5060f2aa5e77
Merge: 260677a eb21fb8
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Thu May 9 15:54:46 2019 +0200
Merge pull request #8411: [BEAM-7012] Support TestStream in portable Flink Runner
.../core/construction/TestStreamTranslation.java | 2 +-
runners/flink/job-server/flink_job_server.gradle | 6 +++-
.../FlinkStreamingPortablePipelineTranslator.java | 42 ++++++++++++++++++++++
.../flink/FlinkStreamingTransformTranslators.java | 13 ++++++-
.../wrappers/streaming/io/TestStreamSource.java | 11 +++---
5 files changed, 66 insertions(+), 8 deletions(-)