This is an automated email from the ASF dual-hosted git repository. dmvk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1a8c56380c924e25135a13dfdc0a5cb101cfddf1 Merge: 1bd1508 3689296 Author: David Moravek <d...@apache.org> AuthorDate: Mon Jun 1 09:46:07 2020 +0200 Merge pull request #11858: [BEAM-8608] Chain DoFns in Flink batch runner when possible. [BEAM-8608] Chain DoFns in Flink batch runner when possible. .../beam/runners/flink/FlinkCapabilities.java | 34 +++++ .../beam/runners/flink/FlinkCapabilities.java | 34 +++++ .../flink/FlinkBatchTransformTranslators.java | 21 ++- .../translation/functions/FlinkDoFnFunction.java | 156 ++++++++++++++------- .../functions/FlinkStatefulDoFnFunction.java | 7 +- .../src/main/resources/beam/suppressions.xml | 1 + 6 files changed, 194 insertions(+), 59 deletions(-)