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