clear query| facets| time Search criteria: .   Results from 1 to 10 from 463 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-7336] KafkaIO should support inferring schemas when reading Avro - Beam - [issue]
...PubSubIO already supports this.It would also be nice to be able to look up Avro schemas in the Kafka schema registry....    Author: Reuven Lax , 2020-07-11, 03:45
[BEAM-1438] The default behavior for the Write transform doesn't work well with the Dataflow streaming runner - Beam - [issue]
...If a Write specifies 0 output shards, that implies the runner should pick an appropriate sharding. The default behavior is to write one shard per input bundle. This works well with the Dataf...    Author: Reuven Lax , 2020-07-10, 17:57
Unable to read value from state/Unable to fetch data due to token mismatch for key - Beam - [mail # user]
...This error should be benign. It often means that ownership of the work itemwas moved to a different worker (possibly caused by autoscaling or othersource of work rebalancing), so the in-prog...
   Author: Reuven Lax , 2020-07-09, 05:19
[expand - 1 more] - Individual Parallelism support for Flink Runner - Beam - [mail # dev]
...However such a parameter would be specific to a single transform,whereas maxNumWorkers is a global parameter today.On Sat, Jun 27, 2020 at 10:31 PM Daniel Collins wrote:> I could imagine ...
   Author: Reuven Lax , 2020-06-28, 12:30
Processing data of different sizes - Beam - [mail # user]
...How are you grouping the elements today?On Fri, Jun 26, 2020 at 10:27 AM André Missaglia <[EMAIL PROTECTED]> wrote:> Hi everyone>> I'm building a pipeline where I group the el...
   Author: Reuven Lax , 2020-06-26, 18:56
[expand - 3 more] - Error restoring Flink checkpoint - Beam - [mail # user]
...Yes, I agree that serializing coders into the checkpoint creates problems.I'm wondering whether it is possible to serialize the coder URN + argsinstead.On Mon, Jun 22, 2020 at 11:00 PM Ivan ...
   Author: Reuven Lax , 2020-06-23, 06:02
[BEAM-4455] Provide automatic schema registration for Protos - Beam - [issue]
...Need to make sure this is a compatible change...    Author: Reuven Lax , 2020-06-18, 18:26
[BEAM-4461] Create a library of useful transforms that use schemas - Beam - [issue]
...e.g. JoinBy(fields). Project, Filter, etc....    Author: Reuven Lax , 2020-06-18, 18:19
[BEAM-2058] BigQuery load job id should be generated at run time, not submission time - Beam - [issue]
...Currently the job id is generated at submission time, which means that rerunning template jobs will produce the same job id. Generate at run time instead, so a different job id is generated ...    Author: Reuven Lax , 2020-06-18, 17:22
[BEAM-4450] Valildate that OutputReceiver<Row> is only allowed if the output PCollection has a schema - Beam - [issue]
...We don't do this today as coder/schema inference may not be complete at the point where we validate....    Author: Reuven Lax , 2020-06-18, 17:21