You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by go...@apache.org on 2019/01/16 00:06:49 UTC
[beam] branch master updated (0e416e2 -> 5d00f6b)
This is an automated email from the ASF dual-hosted git repository.
goenka pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0e416e2 Merge pull request #7503 from RobbeSneyders/tfrecordio
add d2543a2 [BEAM-6258] Set keep alive ping to 20sec
new 5d00f6b Merge pull request #7415 from angoenka/grpc_keep_alive
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../beam/runners/fnexecution/ServerFactory.java | 13 ++++--
.../runners/portability/fn_api_runner.py | 4 +-
.../runners/portability/portable_runner.py | 6 ++-
.../runners/portability/portable_runner_test.py | 3 +-
.../worker/channel_factory.py} | 46 +++++++++++-----------
.../apache_beam/runners/worker/data_plane.py | 6 ++-
.../apache_beam/runners/worker/log_handler.py | 3 +-
.../apache_beam/runners/worker/sdk_worker.py | 9 +++--
8 files changed, 53 insertions(+), 37 deletions(-)
copy sdks/python/apache_beam/{coders/observable.py => runners/worker/channel_factory.py} (55%)
[beam] 01/01: Merge pull request #7415 from angoenka/grpc_keep_alive
Posted by go...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
goenka pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5d00f6b42304815944dfe46ec7a2d95df510ea44
Merge: 0e416e2 d2543a2
Author: Ankur <an...@users.noreply.github.com>
AuthorDate: Tue Jan 15 16:06:40 2019 -0800
Merge pull request #7415 from angoenka/grpc_keep_alive
[BEAM-6258] Set grpc keep alive on server creation
.../beam/runners/fnexecution/ServerFactory.java | 13 +++++--
.../runners/portability/fn_api_runner.py | 4 +-
.../runners/portability/portable_runner.py | 6 ++-
.../runners/portability/portable_runner_test.py | 3 +-
.../apache_beam/runners/worker/channel_factory.py | 44 ++++++++++++++++++++++
.../apache_beam/runners/worker/data_plane.py | 6 ++-
.../apache_beam/runners/worker/log_handler.py | 3 +-
.../apache_beam/runners/worker/sdk_worker.py | 9 +++--
8 files changed, 75 insertions(+), 13 deletions(-)