github  

Messages by Thread

• [I] [Feature Request]: Flink runner: batch performance improvements [beam] via GitHub
• [PR] [Flink] Re-split and balance bounded source splits in batch [beam] via GitHub
  • Re: [PR] [Flink] Re-split and balance bounded source splits in batch [beam] via GitHub
• [PR] [Flink] Add a dedicated operator for batch combines in the global window [beam] via GitHub
  • Re: [PR] [Flink] Add a dedicated operator for batch combines in the global window [beam] via GitHub
• [PR] [Flink] Reshuffle batch inputs round-robin from deterministic start channels [beam] via GitHub
  • Re: [PR] [Flink] Reshuffle batch inputs round-robin from deterministic start channels [beam] via GitHub
  • Re: [PR] [Flink] Reshuffle batch inputs round-robin from deterministic start channels [beam] via GitHub
• [PR] [Flink] Copy length-prefixed batch records and decode grouping inputs lazily [beam] via GitHub
  • Re: [PR] [Flink] Copy length-prefixed batch records and decode grouping inputs lazily [beam] via GitHub
• [PR] [Flink] Throttle Flink metric updates from source readers [beam] via GitHub
  • Re: [PR] [Flink] Throttle Flink metric updates from source readers [beam] via GitHub
• [PR] [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer [beam] via GitHub
  • Re: [PR] [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer [beam] via GitHub
• [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
  • Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
  • Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
  • Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
  • Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
  • Re: [PR] [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex [beam] via GitHub
• [PR] Keep latest metrics image tags updated and set commit image tags after kubectl apply [beam] via GitHub
• [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] via GitHub
  • Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] via GitHub
• [PR] Enable throttling logic. [beam] via GitHub
  • Re: [PR] Enable throttling logic. [beam] via GitHub
  • Re: [PR] Enable throttling logic in RemoteInference. [beam] via GitHub
  • Re: [PR] Enable throttling logic. [beam] via GitHub
• [PR] Clarify known restriction for model updates via side inputs. [beam] via GitHub
  • Re: [PR] Clarify known restrictions for model updates via side inputs. [beam] via GitHub
  • Re: [PR] Clarify known restrictions for model updates via side inputs. [beam] via GitHub
• [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
  • Re: [PR] update more nodes [beam] via GitHub
• [PR] Bump github.com/moby/moby/client from 0.6.1 to 0.6.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/moby/moby/client from 0.6.1 to 0.6.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/moby/moby/client from 0.6.1 to 0.6.2 in /sdks [beam] via GitHub
• [PR] [Python] Document the import-time default of PeriodicImpulse start_timestamp [beam] via GitHub
  • Re: [PR] [Python] Document the import-time default of PeriodicImpulse start_timestamp [beam] via GitHub
  • Re: [PR] [Python] Document the import-time default of PeriodicImpulse start_timestamp [beam] via GitHub
• [PR] Fix missing method delegations in RunInference wrapper ModelHandlers [beam] via GitHub
  • Re: [PR] Fix missing method delegations in RunInference wrapper ModelHandlers [beam] via GitHub
  • Re: [PR] Fix missing method delegations in RunInference wrapper ModelHandlers [beam] via GitHub
• [PR] [Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful batching [beam] via GitHub
  • Re: [PR] [Python] Support max_batch_weight in BatchElements and honor element_size_fn in stateful batching [beam] via GitHub
• [PR] Correct pickling error check. [beam] via GitHub
  • Re: [PR] Correct pickling error check. [beam] via GitHub
  • Re: [PR] Correct pickling error check. [beam] via GitHub
• [PR] Remove a race with another file write that is not essential to test presence of duplicates. [beam] via GitHub
  • Re: [PR] Remove a race with another file write that is not essential to test presence of duplicates. [beam] via GitHub
  • Re: [PR] Remove a race with another file write that is not essential to test presence of duplicates. [beam] via GitHub
• [I] [Feature Request]: Support Protobuf 7.x in Python SDK [beam] via GitHub
• [PR] Fix JmsIO finalize removal warning and clean up stale Java version logic [beam] via GitHub
  • Re: [PR] Fix JmsIO finalize removal warning and clean up stale Java version logic [beam] via GitHub
  • Re: [PR] Fix JmsIO finalize removal warning and clean up stale Java version logic [beam] via GitHub
  • Re: [PR] Fix JmsIO finalize removal warning and clean up stale Java version logic [beam] via GitHub
• [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] via GitHub
  • Re: [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] via GitHub
  • Re: [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] via GitHub
  • Re: [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] via GitHub
  • Re: [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] via GitHub
  • Re: [PR] [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler [beam] via GitHub
• [PR] simple change [beam] via GitHub
  • Re: [PR] [test] - gemini draft review workflow [beam] via GitHub
  • Re: [PR] [test] - gemini draft review workflow [beam] via GitHub
  • Re: [PR] [test] - gemini draft review workflow [beam] via GitHub
  • Re: [PR] [test] - gemini draft review workflow [beam] via GitHub
  • Re: [PR] [test] - gemini draft review workflow [beam] via GitHub
  • Re: [PR] simple change [beam] via GitHub
  • Re: [PR] [test] - gemini draft review workflow [beam] via GitHub
• Re: [PR] add a draft gemini review check [beam] via GitHub
  • Re: [PR] add a draft gemini review check [beam] via GitHub
  • Re: [PR] add a draft gemini review check [beam] via GitHub
  • Re: [PR] add a draft gemini review check [beam] via GitHub
  • Re: [PR] add a draft gemini review check [beam] via GitHub
  • Re: [PR] add a draft gemini review check [beam] via GitHub
• [PR] Add examples for AWS credentials from a secret manager [beam] via GitHub
  • Re: [PR] Add examples for AWS credentials from a secret manager [beam] via GitHub
  • Re: [PR] Add examples for AWS credentials from a secret manager [beam] via GitHub
• [PR] Bump minimum cryptography bounds beyond known severe CVEs [beam] via GitHub
  • Re: [PR] Bump minimum cryptography bounds beyond known severe CVEs [beam] via GitHub
  • Re: [PR] Bump minimum cryptography bounds beyond known severe CVEs [beam] via GitHub
• [PR] update node to 24 [beam] via GitHub
  • Re: [PR] update node in workflows to 24 [beam] via GitHub
  • Re: [PR] update node in workflows to 24 [beam] via GitHub
  • Re: [PR] update node in workflows to 24 [beam] via GitHub
• [PR] Fix handling of cancelled tickets. [beam] via GitHub
  • Re: [PR] Fix handling of cancelled tickets. [beam] via GitHub
  • Re: [PR] Fix handling of cancelled tickets. [beam] via GitHub
  • Re: [PR] Fix handling of cancelled tickets. [beam] via GitHub
• [PR] [yaml] - fix spanner configs and examples [beam] via GitHub
  • Re: [PR] [yaml] - fix spanner configs and examples [beam] via GitHub
  • Re: [PR] [yaml] - fix spanner configs and examples [beam] via GitHub
  • Re: [PR] [yaml] - fix spanner configs and examples [beam] via GitHub
• [PR] Bump golang.org/x/net from 0.59.0 to 0.61.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.59.0 to 0.61.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.59.0 to 0.61.0 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.8 to 1.20.9 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.8 to 1.20.9 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.8 to 1.20.9 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.2 to 1.47.3 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.2 to 1.47.3 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.2 to 1.47.3 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.11 to 1.23.14 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.11 to 1.23.14 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.11 to 1.23.14 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.11 to 1.23.14 in /sdks [beam] via GitHub
• [PR] Bump github.com/nats-io/nats-server/v2 from 2.15.0 to 2.15.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.15.0 to 2.15.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.15.0 to 2.15.1 in /sdks [beam] via GitHub
• [PR] [Python] Support Protobuf 7.x [beam] via GitHub
  • Re: [PR] [Python] Support Protobuf 7.x [beam] via GitHub
  • Re: [PR] [Python] Support Protobuf 7.x [beam] via GitHub
• Re: [I] Support SetState in Dataflow runner [beam] via GitHub
  • Re: [I] Support SetState in Dataflow runner [beam] via GitHub
• [PR] Update Trivial Inference for Python 3.15 [beam] via GitHub
  • Re: [PR] Update Trivial Inference for Python 3.15 [beam] via GitHub
  • Re: [PR] Update Trivial Inference for Python 3.15 [beam] via GitHub
• [PR] [OpenTelemetry] Resolve inline Secret placeholders in openTelemetryProperties [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Resolve inline Secret placeholders in openTelemetryProperties [beam] via GitHub
• [PR] Update FlareDB runner doc [beam] via GitHub
  • Re: [PR] Update FlareDB runner doc [beam] via GitHub
  • Re: [PR] Update FlareDB runner doc [beam] via GitHub
• [PR] Update portability.md to remove Dataflow Runner v2 reference. [beam] via GitHub
  • Re: [PR] Update portability.md to remove Dataflow Runner v2 reference. [beam] via GitHub
  • Re: [PR] Update portability.md to remove Dataflow Runner v2 reference. [beam] via GitHub
• Re: [I] Support MapState in DataflowRunner [beam] via GitHub
  • Re: [I] Support MapState in DataflowRunner [beam] via GitHub
• [PR] [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique [beam] via GitHub
  • Re: [PR] [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique [beam] via GitHub
  • Re: [PR] [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique [beam] via GitHub
• [I] [Bug]: DataFrame API Series.agg with a list drops the Series name for mean, std, var [beam] via GitHub
  • Re: [I] [Bug]: DataFrame API Series.agg with a list drops the Series name for mean, std, var [beam] via GitHub
  • Re: [I] [Bug]: DataFrame API Series.agg with a list drops the Series name for mean, std, var [beam] via GitHub
• [PR] [Python] Keep the Series name in DataFrame Series.agg with a list [beam] via GitHub
  • Re: [PR] [Python] Keep the Series name in DataFrame Series.agg with a list [beam] via GitHub
  • Re: [PR] [Python] Keep the Series name in DataFrame Series.agg with a list [beam] via GitHub
  • Re: [PR] [Python] Keep the Series name in DataFrame Series.agg with a list [beam] via GitHub
• [I] [Bug]: DataFrame API drop_duplicates and duplicated fail on rows with NaN [beam] via GitHub
  • Re: [I] [Bug]: DataFrame API drop_duplicates and duplicated fail on rows with NaN [beam] via GitHub
• [I] [Feature Request]: Support non-default Google Cloud universe domains (GOOGLE_CLOUD_UNIVERSE_DOMAIN) [beam] via GitHub
• [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
  • Re: [PR] [Python] Don't override the Dataflow endpoint by default [beam] via GitHub
• Re: [PR] [Java] Avoid per-schema RowCoder class generation [beam] via GitHub
• [PR] poll BigQuery matchers on missing tables [beam] via GitHub
  • Re: [PR] poll BigQuery matchers on missing tables [beam] via GitHub
  • Re: [PR] poll BigQuery matchers on missing tables [beam] via GitHub
  • Re: [PR] poll BigQuery matchers on missing tables [beam] via GitHub
  • Re: [PR] poll BigQuery matchers on missing tables [beam] via GitHub
  • Re: [PR] poll BigQuery matchers on missing tables [beam] via GitHub
  • Re: [PR] poll BigQuery matchers on missing tables [beam] via GitHub
• [PR] Upgrade Google Ads to 47.0.0 (API v25) [beam] via GitHub
  • Re: [PR] Upgrade Google Ads to 47.0.0 (API v25) [beam] via GitHub
  • Re: [PR] Upgrade Google Ads to 47.0.0 (API v25) [beam] via GitHub
  • Re: [PR] Upgrade Google Ads to 47.0.0 (API v25) [beam] via GitHub
• [PR] [Python] Add `AwsSecret` to the `Secret` utility [beam] via GitHub
  • Re: [PR] [Python] Add `AwsSecret` to the `Secret` utility [beam] via GitHub
  • Re: [PR] [Python] Add `AwsSecret` to the `Secret` utility [beam] via GitHub
• [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] via GitHub
  • Re: [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] via GitHub
  • Re: [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] via GitHub
  • Re: [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] via GitHub
  • Re: [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] via GitHub
  • Re: [PR] [Python] Default PeriodicImpulse start_timestamp to creation time [beam] via GitHub
• [I] [Feature Request]: Modernize legacy DoFn in BatchElementsExample to use parameter injection [beam] via GitHub
  • Re: [I] [Feature Request]: Modernize legacy DoFn in BatchElementsExample to use parameter injection [beam] via GitHub
• [PR] minor google ads version workflow changes [beam] via GitHub
  • Re: [PR] minor google ads version workflow changes [beam] via GitHub
  • Re: [PR] minor google ads version workflow changes [beam] via GitHub
• [I] [Bug]: PeriodicImpulse and MatchContinuously default start_timestamp is the module import time [beam] via GitHub
  • Re: [I] [Bug]: PeriodicImpulse and MatchContinuously default start_timestamp is the module import time [beam] via GitHub
• [I] [Bug]: Regex.all_matches fails for a regex without groups and drops nested or unmatched groups [beam] via GitHub
  • Re: [I] [Bug]: Regex.all_matches fails for a regex without groups and drops nested or unmatched groups [beam] via GitHub
  • Re: [I] [Bug]: Regex.all_matches fails for a regex without groups and drops nested or unmatched groups [beam] via GitHub
• [PR] [Python] Return every group from Regex.all_matches [beam] via GitHub
  • Re: [PR] [Python] Return every group from Regex.all_matches [beam] via GitHub
  • Re: [PR] [Python] Return every group from Regex.all_matches [beam] via GitHub
  • Re: [PR] [Python] Return every group from Regex.all_matches [beam] via GitHub
  • Re: [PR] [Python] Return every group from Regex.all_matches [beam] via GitHub
  • Re: [PR] [Python] Return every group from Regex.all_matches [beam] via GitHub

• Earlier messages