Edward J. Yoon
Arun C Murthy
Vinod Kumar Vavilapalli
Jarek Jarcec Cecho
Matthias J. Sax
mail # dev
last 7 days (4)
last 30 days (23)
last 90 days (46)
last 6 months (54)
last 9 months (58)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[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-05-23, 18:58
[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-05-22, 23:41
[BEAM-4271] Executable stages allow side input coders to be set and/or queried
...ProcessBundleDescriptors may contain side input references from inner PTransforms. These side inputs do not have explicit coders; instead, SDK harnesses use the PCollection coders by default...
, 2018-05-21, 16:28
[BEAM-4127] Flink portable runner translates streaming pipelines by proto
, 2018-05-18, 03:06
[BEAM-4286] Pooled artifact source
...Because DistributeCache lifetimes are tied to operator lifetimes in Flink, we need a way to wrap operator-scoped artifact sources. Artifacts are inherently job-scoped and should be the same ...
, 2018-05-16, 21:30
[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-05-14, 22:07
[BEAM-4285] Flink batch state request handler
...In order to support side inputs Flink needs a state service request handler. As in the non-portable we can start by handling batch side inputs by Flink broadcast variables.https://github.com...
, 2018-05-14, 18:11
[BEAM-4231] Runner utility for Coder instantiation
...Portable runners need to instantiate coders for communicating with SDK harnesses in a consistent way. They cannot simply instantiate coders as defined by PCollections because some component ...
, 2018-05-14, 18:10
[BEAM-3972] Flink runner translates batch pipelines directly by proto
...The non-portable runner uses reydrated pipelines which lack necessary information. The portable Flink runner needs to translate pipelines directly by proto in order to wire components into i...
, 2018-05-07, 21:45
[BEAM-4130] Portable Flink runner JobService entry point in a Docker container
...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-05-07, 21:43
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