Re: Review ask for Flink Runner Backlog Metric Bug Fix

The bot says there are no reviewers for Flink. Possibly you'll find a volunteer to review it here? On Thu, Feb 23, 2023 at 4:47 PM Talat Uyarer via dev wrote: > Hi, > > I created a bugfix for Flink Runner backlog metrics. I asked OWNERs and > try to run assign reviewer command. But I am not

Introduction and Idea for GSOC 2023.

HELLO Pablo, I hope this email finds you well. My name is Siddharth Aryan a 2 year undergrad student in Bachelors in Computer Application, and a student who is very interested in participating in Google Summer of Code this year. I am writing to introduce myself and express my interest in your

Re: Review ask for Flink Runner Backlog Metric Bug Fix

Would you like to be a volunteer +Andrew Pilloud :) On Thu, Feb 23, 2023 at 4:51 PM Andrew Pilloud wrote: > The bot says there are no reviewers for Flink. Possibly you'll find a > volunteer to review it here? > > On Thu, Feb 23, 2023 at 4:47 PM Talat Uyarer via dev > wrote: > >> Hi, >> >> I

Re: Beam Release 2.46

Thanks for the update! I'd like to suggest that we include in the release voting email template a link to a PR that runs all tests against the release branch. I think we used to include it, but I haven't seen it in recent voting threads. Thanks, Valentyn On Thu, Feb 23, 2023 at 9:28 AM Danny

Review ask for Flink Runner Backlog Metric Bug Fix

Hi, I created a bugfix for Flink Runner backlog metrics. I asked OWNERs and try to run assign reviewer command. But I am not sure. I pressed the right button :) If you know some who can review this change https://github.com/apache/beam/pull/25554 Could you assign him/her to this mr ? Thanks

Beam Website Feedback: Request: Docon Error handling patterns

It’d be nice to see some common error handling patterns; 1) how to handle per op bases : map, flatMap, parDo 2) how to handle uniformly across multiple ops ..

Re: Consuming one PCollection before consuming another with Beam

Can you explain this use case some more? Is this a streaming pipeline? If so, how are you reading from BigQuery? On Thu, Feb 23, 2023 at 10:06 PM Sahil Modak via dev wrote: > Hi, > > We have a requirement wherein we are consuming input from pub/sub > (PubSubIO) as well as BQ (BQIO) > > We want

Consuming one PCollection before consuming another with Beam

Hi, We have a requirement wherein we are consuming input from pub/sub (PubSubIO) as well as BQ (BQIO) We want to make sure that we consume the BQ stream first before we start consuming the data from pub-sub. Is there a way to achieve this? Can you please help with some code samples? Currently,

Beam High Priority Issue Report (37)

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/25601 [Failing Test]:

Re: Beam Release 2.46

I cut the release branch yesterday at commit 4ce8eeda19699cc64ae8cf310267a478cfe9e4b8 . There is currently one open release blocking issue : - #25601: [Failing Test]: Python

Beam Dependency Check Report (2023-02-23)

<<< text/html; charset=UTF-8: Unrecognized >>>