This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit a8368a06e60839125fba13428f2b5db6dc05f9c3 Merge: 2249be9 ee81e25 Author: Kenn Knowles <[email protected]> AuthorDate: Thu Jan 18 11:52:34 2018 -0800 Merge pull request #4384: [BEAM-2795] Use portable constructs in Flink streaming translator .../runners/core/construction/UnconsumedReads.java | 4 +- runners/flink/pom.xml | 5 + .../runners/flink/CreateStreamingFlinkView.java | 26 +++- .../flink/FlinkPipelineExecutionEnvironment.java | 9 ++ .../flink/FlinkStreamingPipelineTranslator.java | 6 +- .../flink/FlinkStreamingTransformTranslators.java | 157 +++++++++++++++------ .../runners/flink/FlinkTransformOverrides.java | 9 +- 7 files changed, 159 insertions(+), 57 deletions(-) -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
