clear query| facets| time Search criteria: *:*.   Results from 1 to 10 from 377 (0.0s).
Loading phrases to help you
refine your search...
[SPARK-32083] Unnecessary tasks are launched when input is empty with AQE - Spark - [issue]
...https://github.com/apache/spark/pull/28226 meant to avoid launching unnecessary tasks for 0-size partitions when AQE is enabled. However, when all partitions are empty, the number of partiti...
http://issues.apache.org/jira/browse/SPARK-32083    Author: Manu Zhang , 2020-06-30, 11:58
[BEAM-1119] Add a trigger that fires when the watermark passes timestamp - Beam - [issue]
...For a pane with elements and timestamps [(a, 1), (b, 4), (c, 5)], "a" would be emitted if watermark passes 1 "a" and "b" would be emitted if watermark passes 4 all the elements woul...
http://issues.apache.org/jira/browse/BEAM-1119    Author: Manu Zhang , 2020-06-25, 17:26
[BEAM-2694] Python shim for submitting to GearpumpRunner - Beam - [issue]
...Shamelessly copied from Kenn's descriptions in other jiras,Whatever the result of https://s.apache.org/beam-job-api, Python users will need to be able to pass --runner=GearpumpRunner and hav...
http://issues.apache.org/jira/browse/BEAM-2694    Author: Manu Zhang , 2020-06-25, 17:25
[BEAM-2695] GearpumpRunner shim for Job API - Beam - [issue]
...From Kenn's descriptions in other jiras,Whatever the result of https://s.apache.org/beam-job-api we will need a way for the JVM-based GearpumpRunner to receive and run pipelines authors in P...
http://issues.apache.org/jira/browse/BEAM-2695    Author: Manu Zhang , 2020-06-25, 17:25
[BEAM-1180] Implement GearpumpPipelineResult - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-1180    Author: Manu Zhang , 2020-06-18, 17:22
[BEAM-2691] Add gearpump-runner to jenkins-precommit tests - Beam - [issue]
...We are not able to do so now because {{java.lang.NoClassDefFoundError: Could not initialize class org.apache.beam.sdk.options.PipelineOptionsFactory} will be thrown if flink-runner and gearp...
http://issues.apache.org/jira/browse/BEAM-2691    Author: Manu Zhang , 2020-06-18, 17:22
[BEAM-2693] GearpumpRunner Fn API based ParDo operator - Beam - [issue]
...This is copied from Kenn's description in other jiras.To run non-Java SDK code is to put together an operator that manages a Fn API client DoFnRunner and an SDK harness Fn API server.(filing...
http://issues.apache.org/jira/browse/BEAM-2693    Author: Manu Zhang , 2020-06-18, 17:22
[BEAM-2692] Post-merge change to Beam website for gearpump-runner - Beam - [issue]
...Add gearpump-runner to "QuickStart-Java" page Add gearpump-runner to "WordCount" page Remove "Under development" on "Using the Documentation" page Remove gearpump-runner from feature-branche...
http://issues.apache.org/jira/browse/BEAM-2692    Author: Manu Zhang , 2020-06-18, 17:22
[BEAM-2698] Support Splittable DoFn in GearpumpRunner - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-2698    Author: Manu Zhang , 2020-06-18, 17:22
[BEAM-2697] Support for new Timer API in GearpumpRunner - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-2697    Author: Manu Zhang , 2020-06-18, 17:22