Edward J. Yoon
Arun C Murthy
Vinod Kumar Vavilapalli
Matthias J. Sax
Jarek Jarcec Cecho
mail # dev
last 7 days (3)
last 30 days (6)
last 90 days (21)
last 6 months (53)
last 9 months (63)
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-08-13, 22:35
[BEAM-5110] Reconile Flink JVM singleton management with deployment
...Ankur Goenka noticed through debugging that multiple instances of BatchFlinkExecutableStageContext.BatchFactory are loaded for a given job when executing in standalone cluster mode. This con...
, 2018-08-13, 19:56
[BEAM-5114] Create example uber jars for supported runners
...Producing these artifacts results in several benefits Gives an example of how to package user code for different runners Enables ad-hoc testing of runner changes against real user pipelines ...
, 2018-08-10, 17:47
[BEAM-4148] Local server api descriptors contain urls that work on Mac and Linux
...Docker for Mac does not allow host networking and thus will not allow SDK harnesses to access runner services via `localhost`. Instead, a special DNS name is used to refer to the host machin...
, 2018-08-04, 00:19
[BEAM-4147] Abstractions for artifact delivery via arbitrary storage backends
...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-08-01, 22:30
[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-08-01, 22:03
[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
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