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:04 UTC

[beam] 01/01: Merge pull request #8411: [BEAM-7012] Support TestStream in portable Flink Runner

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(-)