[beam] branch master updated (76fcf15 -> 325039b)

[ch...@apache.org]

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

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


    from 76fcf15  [BEAM-8280][BEAM-8629] Make IOTypeHints immutable (#10735)
     add e348629  [BEAM-7961] Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite
     add 325039b  Merge pull request #10051: [BEAM-7961] Add tests for all runner native transforms for XLang

No new revisions were added by this update.

Summary of changes:
 ...ommit_CrossLanguageValidatesRunner_Flink.groovy |   9 +
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |  30 +-
 .../runners/core/construction/ExternalTest.java    |  74 ++---
 .../core/construction/ValidateRunnerXlangTest.java | 245 ++++++++++++++
 runners/flink/job-server/flink_job_server.gradle   |  26 +-
 sdks/java/testing/expansion-service/build.gradle   |   6 +-
 .../beam/sdk/expansion/TestExpansionService.java   |  97 ------
 .../testing/expansion/TestExpansionService.java    | 355 +++++++++++++++++++++
 sdks/python/apache_beam/coders/coders.py           |   4 +-
 .../io/external/xlang_parquetio_test.py            |   7 +-
 .../runners/portability/expansion_service_test.py  | 146 ++++++++-
 sdks/python/apache_beam/transforms/external.py     |   3 +-
 .../python/apache_beam/transforms/external_java.py | 179 +++++++++++
 .../python/apache_beam/transforms/external_test.py | 184 +----------
 .../transforms/validate_runner_xlang_test.py       | 196 ++++++++++++
 ...pansion_services.sh => run_flink_job_server.sh} |  54 ++--
 sdks/python/test-suites/portable/py2/build.gradle  |   4 +-
 17 files changed, 1227 insertions(+), 392 deletions(-)
 create mode 100644 runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/ValidateRunnerXlangTest.java
 delete mode 100644 sdks/java/testing/expansion-service/src/test/java/org/apache/beam/sdk/expansion/TestExpansionService.java
 create mode 100644 sdks/java/testing/expansion-service/src/test/java/org/apache/beam/sdk/testing/expansion/TestExpansionService.java
 create mode 100644 sdks/python/apache_beam/transforms/external_java.py
 create mode 100644 sdks/python/apache_beam/transforms/validate_runner_xlang_test.py
 copy sdks/python/scripts/{run_expansion_services.sh => run_flink_job_server.sh} (61%)