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...
http://issues.apache.org/jira/browse/BEAM-4130    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 ...
http://issues.apache.org/jira/browse/BEAM-5114    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....
http://issues.apache.org/jira/browse/BEAM-4176    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....
http://issues.apache.org/jira/browse/BEAM-3885    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...
http://issues.apache.org/jira/browse/BEAM-3676    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....
http://issues.apache.org/jira/browse/BEAM-3675    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...
http://issues.apache.org/jira/browse/BEAM-5110    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.https://github.com...
http://issues.apache.org/jira/browse/BEAM-4285    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....
http://issues.apache.org/jira/browse/BEAM-3884    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...
http://issues.apache.org/jira/browse/BEAM-4615    Author: Ben Sidhom , 2018-09-11, 16:29