clear query| facets| time Search criteria: .   Results from 1 to 10 from 63 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-4130] Portable Flink runner JobService entry point in a Docker container - Beam - [issue]
...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...    Author: Ben Sidhom , 2018-10-17, 01:14
[BEAM-5114] Create example uber jars for supported runners - Beam - [issue]
...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 ...    Author: Ben Sidhom , 2018-10-16, 18:18
[BEAM-4176] Java: Portable batch runner passes all ValidatesRunner tests that non-portable runner passes - Beam - [issue]
...We need this as a sanity check that runner execution is correct....    Author: Ben Sidhom , 2018-10-16, 17:54
[BEAM-3885] Python SDK Read IO is expressed as Impulse -> ParDo - Beam - [issue]
...Portable runners cannot understand SDK-specific Read transforms. The Python SDK will need to rewrite Read as Impulse followed by a ParDo that actually does the IO....    Author: Ben Sidhom , 2018-10-15, 09:00
[BEAM-3676] FlinkRunner: Portable state service - Beam - [issue]
...The State API is an implementation of BeamFnState that exposes pipeline state to SDK harnesses. Because it is used for side inputs, this service will also need to be tied into side inputs/ou...    Author: Ben Sidhom , 2018-10-08, 13:58
[BEAM-3675] FlinkRunner: Logging server - Beam - [issue]
...An implementation of BeamFnLogging that uses the default Flink logging mechanism....    Author: Ben Sidhom , 2018-09-20, 16:28
[BEAM-5110] Reconile Flink JVM singleton management with deployment - Beam - [issue]
...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...    Author: Ben Sidhom , 2018-09-20, 16:19
[BEAM-4285] Flink batch state request handler - Beam - [issue]
...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.    Author: Ben Sidhom , 2018-09-20, 16:16
[BEAM-3884] Python SDK supports Impulse as a primitive transform - Beam - [issue]
...Portable runners require Impulse to be the only root nodes of pipelines. The Python SDK should provide this for pipeline construction....    Author: Ben Sidhom , 2018-09-20, 07:41
[BEAM-4615] Flink job server driver wrapper - Beam - [issue]
...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...    Author: Ben Sidhom , 2018-09-11, 16:29