Edward J. Yoon
Arun C Murthy
Vinod Kumar Vavilapalli
Jarek Jarcec Cecho
Matthias J. Sax
mail # dev
last 7 days (26)
last 30 days (31)
last 90 days (45)
last 6 months (53)
last 9 months (53)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[BEAM-4109] Support arbitrary artifact names in local file artifact staging service
...The local-file based artifact staging service implementation stores artifacts in a flat directory under the exact names they are given by the artifact staging request. This assumes that all ...
, 2018-04-21, 00:58
[BEAM-3886] Python SDK harness uses State API from ProcessBundleDescriptor
...The Python harness should pull the state api descriptor from the current process bundle descriptor when processing bundles.As a minor optimization and to make implementing new runners easier...
, 2018-04-20, 23:33
[BEAM-4151] Prevent control client pool service from leaking stale client references
...The pool service that connects incoming gRPC control clients to consumers may leak client references. See https://github.com/apache/beam/pull/5189#discussion_r183144364 for context.It's wort...
, 2018-04-20, 21:51
[BEAM-4067] Add portable Flink test runner
...The portable Flink runner cannot be tested through the normal mechanisms used for ValidatesRunner tests because it requires a job server to be constructed out of band and for pipelines to be...
, 2018-04-20, 20:48
[BEAM-4130] Portable Flink runner entry point
...The portable Flink runner exists as a Job Service that runs somewhere. We need a main entry point that itself spins up the job service (and artifact staging service). The main program itself...
, 2018-04-20, 20:48
[BEAM-3970] Java SDK harness supports window_into
...The Java SDK harness does not currently register a PTransformRunnerFactory for beam:transform:window_into:v1. We need this functionality for GroupByKey transforms....
, 2018-04-19, 23:25
[BEAM-3883] Python SDK stages artifacts when talking to job server
...The Python SDK does not currently stage its user-defined functions or dependencies when talking to the job API. Artifacts that need to be staged include the user code itself, any SDK compone...
, 2018-04-19, 23:02
[BEAM-4147] Portable runner Job API abstractions
...We need a way to wire in arbitrary runner artifact storage backends into the job server and through to artifact staging on workers. This requires some new abstractions in front of the job se...
, 2018-04-19, 22:23
[BEAM-4146] Python SDK sets environment in portable pipelines
...Environments must be set in any non-runner-executed transforms. See https://github.com/bsidhom/beam/commit/0362fd1f25 for a possible approach until canonical image urls are created....
, 2018-04-19, 22:10
[BEAM-4145] Java SDK Harness populates control request headers with worker id
...Runner code needs to be able to identify incoming harness connections by the worker ids that it assigns to them on creation. This is currently done by the go boot code when the harness runs ...
, 2018-04-19, 21:29
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by