This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2ef7b9d Merge pull request #11695: [BEAM-9985] Disambiguate method
filter for toArray for Java 11.
add a5b2046 [BEAM-9001, BEAM-6327] Ensure that all transforms (except for
required runner implemented transforms) have an environment id. (#11670)
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 18 ++++++---
.../core/construction/PTransformTranslation.java | 40 +++++++++++--------
.../core/construction/graph/PipelineValidator.java | 9 +++++
...er.java => TrivialNativeTransformExpander.java} | 45 ++++++++++++----------
.../construction/graph/QueryablePipelineTest.java | 6 ++-
.../beam/runners/flink/FlinkPipelineRunner.java | 5 ++-
.../FlinkStreamingPortablePipelineTranslator.java | 2 +-
.../beam/runners/spark/SparkPipelineRunner.java | 5 ++-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 22 ++++++-----
sdks/python/apache_beam/pipeline.py | 24 +++++-------
10 files changed, 106 insertions(+), 70 deletions(-)
rename
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/{PipelineTrimmer.java
=> TrivialNativeTransformExpander.java} (54%)
