Radosław Stankiewicz

[Drain] OnTimer - propagate caused by drain bit up to DoFnRunner

4

Stacked on top of https://github.com/apache/beam/pull/37009 ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the appropriate issue...

Cache DynamicDestinationsHelper.ConstantTimePartitioningClusteringDestination clustering & partitioning

5

Fixes #36989 DynamicDestinationsHelper.ConstantTimePartitioningClusteringDestinations is parsing per element json configuration for partitioning and clustering which is expensive. Cache the outcome of evaluation so it's done once. ------------------------ Thank you for your...

[Bug]: BigQueryIO performance overhead on DynamicDestinations on parsing json

7

### What happened? Where: https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinationsHelpers.java#L305-L314 Why: validation of static valueprovider is per element Impact: 20% overhead on this stage. Request: store outcome of validation within the object itself. ### Issue...

### Related Template(s) All ### Template Version All ### What happened? problem statement: it's difficult to decide if to accept PR from dependabot this is toil but it will help...