Hey all,
I've been really trying to use Playground for educating new Beam users but
it feels like there's something missing. A lot of examples (e.g. Multiple
ParDo Outputs) for at least the python API don't seem to do anything
observable. For example, the Multiple ParDo Outputs example writes to
+1 (non-binding)
Validated with a simple RunInference Python pipeline:
https://github.com/google/dataflow-ml-starter/actions/runs/7821639833/job/21339032997
On Wed, Feb 7, 2024 at 7:10 PM Yi Hu via dev wrote:
> +1 (non-binding)
>
> Validated with Dataflow Template:
>
+1 (non-binding)
Validated with Dataflow Template:
https://github.com/GoogleCloudPlatform/DataflowTemplates/pull/1317
Regards,
On Wed, Feb 7, 2024 at 11:18 AM Ritesh Ghorse via dev
wrote:
> +1 (non-binding)
>
> Ran a few batch and streaming examples for Python SDK on Dataflow Runner
>
>
OK, so my stance is a configurable Reshuffle might be interesting, so my vote
is +1, along the following lines.
1. Use a new URN (beam:transform:reshuffle:v2) and attach a new
ReshufflePayload to it.
-> Unknown "urns for composite transforms" already default to the
subtransform graph
On Wed, Feb 7, 2024 at 1:34 AM Sam Whittle via dev
wrote:
> Related to this, could a PMC member add my key to
> https://dist.apache.org/repos/dist/release/beam/KEYS?
>
Done, thanks.
> I've appended it to https://dist.apache.org/repos/dist/dev/beam/KEYS
> Thanks!
> Sam
>
> On Wed, Feb 7, 2024 at
+1 (non-binding)
Ran a few batch and streaming examples for Python SDK on Dataflow Runner
Thanks!
On Wed, Feb 7, 2024 at 4:08 AM Jan Lukavský wrote:
> +1 (binding)
>
> Validated Java SDK with Flink runner.
>
> Jan
> On 2/7/24 06:23, Robert Burke via dev wrote:
>
> Hi everyone,
> Please
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/29971 [Bug]:
Related to this, could a PMC member add my key to
https://dist.apache.org/repos/dist/release/beam/KEYS?
I've appended it to https://dist.apache.org/repos/dist/dev/beam/KEYS
Thanks!
Sam
On Wed, Feb 7, 2024 at 12:15 AM Kenneth Knowles wrote:
> SGTM. Thanks for doing this!
>
> On Tue, Feb 6, 2024
+1 (binding)
Validated Java SDK with Flink runner.
Jan
On 2/7/24 06:23, Robert Burke via dev wrote:
Hi everyone,
Please review and vote on the release candidate #2 for the version 2.54.0,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific