This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from f731211 [BEAM-9346] Improve the efficiency of TFRecordIO (#11122)
add cf3ce65 [BEAM-9433] Create expansion service artifact for common Java
IOs.
add 311b90d Log in a daemon thread.
add 55d374e Merge pull request #11048 [BEAM-9433] Create expansion
service artifact for common Java IOs.
No new revisions were added by this update.
Summary of changes:
.../sdk/expansion/service/ExpansionService.java | 14 +++-
.../java/io/expansion-service}/build.gradle | 29 +++----
sdks/python/apache_beam/io/external/kafka.py | 17 ++--
.../apache_beam/runners/portability/job_server.py | 5 --
sdks/python/apache_beam/transforms/external.py | 4 +-
sdks/python/apache_beam/utils/subprocess_server.py | 43 +++++++---
.../apache_beam/utils/subprocess_server_test.py | 95 ++++++++++++++++++++++
settings.gradle | 1 +
8 files changed, 163 insertions(+), 45 deletions(-)
copy {runners/samza/job-server => sdks/java/io/expansion-service}/build.gradle
(60%)
create mode 100644 sdks/python/apache_beam/utils/subprocess_server_test.py
