Re: [ANNOUNCE] New committer: Steven Niemitz

2022-07-20 Thread Moritz Mack
Congrats, Steven! On 21.07.22, 05:25, "Evan Galpin" wrote: Congrats! Well deserved! On Wed, Jul 20, 2022 at 15:⁠​17 Chamikara Jayalath via dev wrote:⁠​ Congrats, Steve! On Wed, Jul 20, 2022, 9:⁠​16 AM Austin Bennett wrote:⁠​ Great! ‍ ‍ ‍ ‍ ‍ ‍ ‍ ‍ ‍ ZjQcmQRYFpfptBannerStart ZjQcmQRYFpfptB

Re: Using unbounded source as a side input for a DoFn

2022-07-20 Thread Cristian Constantinescu
Disclaimer: I am not an expert, but I kinda worked on something similar. A few points I'd like to bring up: - Side inputs do not trigger the processElement function when new elements are added to the input. That means that if your side input doesn't have the desired other item in the side input at

Re: Using unbounded source as a side input for a DoFn

2022-07-20 Thread Reuven Lax via dev
How do you want to use the side input? On Wed, Jul 20, 2022 at 10:45 PM Sahil Modak wrote: > Hi, > > We are looking to use the side input feature for one of our DoFns. The > side input has to be a PCollection which is being constructed from a > subscription using PubsubIO.read > > We want our pr

Using unbounded source as a side input for a DoFn

2022-07-20 Thread Sahil Modak
Hi, We are looking to use the side input feature for one of our DoFns. The side input has to be a PCollection which is being constructed from a subscription using PubsubIO.read We want our primary DoFn which operates in a global window KV pair to access this side input. The goal is to have all th

Re: [ANNOUNCE] New committer: Steven Niemitz

2022-07-20 Thread Evan Galpin
Congrats! Well deserved! On Wed, Jul 20, 2022 at 15:17 Chamikara Jayalath via dev < dev@beam.apache.org> wrote: > Congrats, Steve! > > On Wed, Jul 20, 2022, 9:16 AM Austin Bennett > wrote: > >> Great! >> >> On Wed, Jul 20, 2022 at 10:11 AM Aizhamal Nurmamat kyzy < >> aizha...@apache.org> wrote:

Re: [ANNOUNCE] New committer: Steven Niemitz

2022-07-20 Thread Chamikara Jayalath via dev
Congrats, Steve! On Wed, Jul 20, 2022, 9:16 AM Austin Bennett wrote: > Great! > > On Wed, Jul 20, 2022 at 10:11 AM Aizhamal Nurmamat kyzy < > aizha...@apache.org> wrote: > >> Congrats, Steve! >> >> On Wed, Jul 20, 2022 at 3:10 AM Jan Lukavský wrote: >> >>> Congrats Steve! >>> On 7/20/22 06:20,

Re: [ANNOUNCE] New committer: Steven Niemitz

2022-07-20 Thread Austin Bennett
Great! On Wed, Jul 20, 2022 at 10:11 AM Aizhamal Nurmamat kyzy wrote: > Congrats, Steve! > > On Wed, Jul 20, 2022 at 3:10 AM Jan Lukavský wrote: > >> Congrats Steve! >> On 7/20/22 06:20, Reuven Lax via dev wrote: >> >> Welcome Steve! >> >> On Tue, Jul 19, 2022 at 1:05 PM Connell O'Callaghan via

Re: [ANNOUNCE] New committer: Steven Niemitz

2022-07-20 Thread Aizhamal Nurmamat kyzy
Congrats, Steve! On Wed, Jul 20, 2022 at 3:10 AM Jan Lukavský wrote: > Congrats Steve! > On 7/20/22 06:20, Reuven Lax via dev wrote: > > Welcome Steve! > > On Tue, Jul 19, 2022 at 1:05 PM Connell O'Callaghan via dev < > dev@beam.apache.org> wrote: > >> >> +++1 Woohoo! Congratulations Steven (and

Beam High Priority Issue Report

2022-07-20 Thread beamactions
This is your daily summary of Beam's current high priority issues that may need attention. See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities. Unassigned P1 Issues: https://github.com/apache/beam/issues/22321 PortableRunnerTest

Re: [ANNOUNCE] New committer: Steven Niemitz

2022-07-20 Thread Jan Lukavský
Congrats Steve! On 7/20/22 06:20, Reuven Lax via dev wrote: Welcome Steve! On Tue, Jul 19, 2022 at 1:05 PM Connell O'Callaghan via dev wrote: +++1 Woohoo! Congratulations Steven (and to the BEAM community) on this announcement!!! Thank you Luke for this update On Tue