Edward J. Yoon
Arun C Murthy
Vinod Kumar Vavilapalli
Matthias J. Sax
Jarek Jarcec Cecho
mail # dev
last 7 days (2)
last 30 days (13)
last 90 days (31)
last 6 months (53)
last 9 months (61)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[BEAM-4176] Java: Portable batch runner passes all ValidatesRunner tests that non-portable runner passes
...We need this as a sanity check that runner execution is correct....
, 2018-07-18, 23:15
[BEAM-4067] Java: FlinkPortableTestRunner: runs portably via self-started local Flink
...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-07-12, 21:52
[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-07-06, 23:33
[BEAM-3971] Pipeline translation utilities should not use SDK construction classes
...In general, portable runners will require access to pipeline information not available in rehydrated pipelines while constructing physical plans. Translation utilities should operate directl...
, 2018-07-02, 19:52
[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-06-29, 18:54
[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-06-28, 23:09
[BEAM-3966] Move core utilities into a new top-level module
...As part of a longer-term dependency cleanup, fn-execution and similar utilities should be moved into a new top-level module (util?) that can be shared among runner and/or SDK code while clea...
, 2018-06-28, 16:25
[BEAM-4615] Flink job server driver wrapper
...This includes: A gradle wrapper that can execute the Flink job server driver so that it can be easily run locally for testing/debugging. A shadow ("uber") target that packages all portable F...
, 2018-06-26, 00:24
[BEAM-4523] Implement Flink batch ExecutableStage context
...The the ExecutableStage context is a wrapper for the job and stage bundle factories and pooled artifact sources. It should take care of caching the overall job bundle factory since we do not...
, 2018-06-21, 21: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-06-21, 21:10
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