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 164f249 Update env variable name in sync script
add b45bc6f [BEAM-6683] add createCrossLanguageValidatesRunner task
add 9678149 Merge pull request #8174: [BEAM-6683] add
createCrossLanguageValidatesRunner task
No new revisions were added by this update.
Summary of changes:
...mmit_CrossLanguageValidatesRunner_Flink.groovy} | 8 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 133 +++++++++++++++++++-
runners/core-construction-java/build.gradle | 21 ----
.../runners/core/construction/ExternalTest.java | 47 +++----
.../expansion/TestExpansionService.java | 58 ---------
runners/flink/job-server/flink_job_server.gradle | 30 ++---
sdks/java/testing/expansion-service/build.gradle | 52 ++++++++
.../beam/sdk/expansion/TestExpansionService.java | 101 +++++++++++++++
sdks/python/apache_beam/coders/avro_coder.py | 99 ---------------
sdks/python/apache_beam/coders/avro_coder_test.py | 71 -----------
.../job/utils.py => coders/avro_record.py} | 22 ++--
sdks/python/apache_beam/coders/coder_impl.py | 23 ++++
sdks/python/apache_beam/coders/coders.py | 41 ++++++-
sdks/python/apache_beam/coders/coders_test.py | 43 +++++++
.../apache_beam/coders/coders_test_common.py | 1 +
.../python/apache_beam/examples/wordcount_xlang.py | 2 +-
.../apache_beam/io/external/generate_sequence.py | 5 +-
.../external/generate_sequence_test.py} | 55 +++++----
.../io/external/xlang_parquetio_test.py | 88 +++++++++++++
.../runners/portability/expansion_service_test.py | 50 +++++---
sdks/python/apache_beam/testing/test_pipeline.py | 3 +
sdks/python/apache_beam/transforms/combiners.py | 4 +-
.../python/apache_beam/transforms/external_test.py | 76 ++++++------
sdks/python/scripts/run_expansion_services.sh | 136 +++++++++++++++++++++
sdks/python/test-suites/portable/py2/build.gradle | 8 +-
settings.gradle | 1 +
26 files changed, 776 insertions(+), 402 deletions(-)
copy
.test-infra/jenkins/{job_PostCommit_Java_PortableValidatesRunner_Flink_Batch.groovy
=> job_PostCommit_CrossLanguageValidatesRunner_Flink.groovy} (80%)
delete mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/expansion/TestExpansionService.java
create mode 100644 sdks/java/testing/expansion-service/build.gradle
create mode 100644
sdks/java/testing/expansion-service/src/test/java/org/apache/beam/sdk/expansion/TestExpansionService.java
delete mode 100644 sdks/python/apache_beam/coders/avro_coder.py
delete mode 100644 sdks/python/apache_beam/coders/avro_coder_test.py
copy sdks/python/apache_beam/{runners/job/utils.py => coders/avro_record.py}
(69%)
copy sdks/python/apache_beam/{examples/complete/game/hourly_team_score_test.py
=> io/external/generate_sequence_test.py} (52%)
create mode 100644 sdks/python/apache_beam/io/external/xlang_parquetio_test.py
create mode 100755 sdks/python/scripts/run_expansion_services.sh
