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

Posted to commits@beam.apache.org by ja...@apache.org on 2021/08/25 17:09:15 UTC

[beam] branch master updated (2e5162e -> b236713)

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

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


    from 2e5162e  Merge pull request #15387 from ibzib/ignore-recommendation-py
     add a4a6f7b  [BEAM-12704] Failing test for Flink primitive Read
     add f17b66d  [BEAM-12704] Primitive Read working on Flink
     add b236713  Merge pull request #15370: [BEAM-12704] flink primitive read

No new revisions were added by this update.

Summary of changes:
 .../FlinkStreamingPortablePipelineTranslator.java  | 187 +++++++++++++++++----
 .../translation/types/CoderTypeSerializer.java     |  11 +-
 .../translation/wrappers/SourceInputFormat.java    |   6 +-
 .../streaming/ExecutableStageDoFnOperator.java     |   5 +
 .../beam/runners/flink/ReadSourcePortableTest.java | 134 ++++++++++++++-
 5 files changed, 297 insertions(+), 46 deletions(-)