clear query| facets| time Search criteria: .   Results from 41 to 50 from 35482 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-5791] Bound the amount of data on the data plane by time. - Beam - [issue]
...This is especially important for Fn API reads, where each element represents a shard to read and may be very expensive, but many elements may be waiting in the Fn API buffer.The need for thi...
http://issues.apache.org/jira/browse/BEAM-5791    Author: Robert Bradshaw , 2018-10-19, 15:18
[BEAM-5438] Add Gemfire IO - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-5438    Author: zhangbin , 2018-10-19, 15:02
[BEAM-5792] Use Impulse + Reshuffle for Create on Fn API - Beam - [issue]
...There's little advantage to shuffling the splits rather than shuffling the elements themselves,and some real-world experience showed significant disadvantages....
http://issues.apache.org/jira/browse/BEAM-5792    Author: Robert Bradshaw , 2018-10-19, 14:48
[BEAM-3450] RemoteGrpcPorts should contain the wire format - Beam - [issue]
...This forces the runner to include the wire format independently from a PCollection coder, which should be the coder of the type of the PCollection (e.g. in Java, PCollection<T> has Cod...
http://issues.apache.org/jira/browse/BEAM-3450    Author: Thomas Groh , 2018-10-19, 07:09
[BEAM-5782] BigQuery TableRows not cloneable when using Dataflow - Beam - [issue]
...TableRows are expected to be cloneable.BigQueryAvroUtils converts repeated records using an ImmutableList which is not cloneable. Reproduction steps:1. Clone the code https://github.com/nahu...
http://issues.apache.org/jira/browse/BEAM-5782    Author: Luke Cwik , 2018-10-18, 23:52
[expand - 2 more] - When will the Dataflow Runner invoke the UnboundedReader.close() method and decode the checkpoint? - Beam - [mail # dev]
...Thanks Raghu, this is very helpful!On Friday, October 19, 2018, Raghu Angadi  wrote:> Decoding checkpoint is required only while resuming a reader. Typically> this happens: while ...
   Author: flyisland , Raghu Angadi , ... , 2018-10-18, 23:06
[BEAM-5366] Vendor gRPC and Protobuf separately from beam-model-* Java packages - Beam - [issue]
...Each of the beam-model-* jars currently contains duplicate definitions of gRPC and protobuf and their transitive dependencies. By migrating those packages to a separate artifact, we could ha...
http://issues.apache.org/jira/browse/BEAM-5366    Author: Luke Cwik , 2018-10-18, 21:21
[expand - 12 more] - [PROPOSAL] Using Bazel and Docker for Python SDK development and tests - Beam - [mail # dev]
...On Thu, Oct 18, 2018 at 9:19 PM Udi Meiri  wrote:> Unless I'm missing something, we can't run cython builds in parallel with> other builds without first making cython build artifa...
   Author: Robert Bradshaw , Udi Meiri , ... , 2018-10-18, 20:25
[BEAM-2918] Flink support for portable user state - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-2918    Author: Henning Rohde , 2018-10-18, 18:14
[BEAM-5789] [SQL] CASE CAST(.. as DATE) ELSE NULL doesn't work - Beam - [issue]
...CASE CAST(.. as DATE) ELSE NULL    seem to result in multiple conversions from string to date. That chain seems to fail as one of the string representations of the date is not supported by C...
http://issues.apache.org/jira/browse/BEAM-5789    Author: Anton Kedin , 2018-10-18, 18:00