beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chamik...@apache.org
Subject [beam] branch master updated (164f249 -> 9678149)
Date Tue, 06 Aug 2019 21:29:51 GMT
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


Mime
View raw message