github  

Messages by Thread

• [I] [Task]: Python schema generated types uses schema registry and coder registry [beam] via GitHub
• Re: [I] Introduce SchemaTransform API [beam] via GitHub
  • Re: [I] Introduce SchemaTransform API [beam] via GitHub
• [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
• Re: [I] [Bug]: DualInputNestedValueProvider is not able to get Value properly if input is RuntimeValueProvider. [beam] via GitHub
• Re: [I] [Bug]: Cannot read from ssl-enabled cassandra cluster [beam] via GitHub
• [PR] [wip] update deserialization [beam] via GitHub
  • Re: [PR] [wip] update deserialization [beam] via GitHub
• [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
  • Re: [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
  • Re: [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
  • Re: [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
• [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
• [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] via GitHub
• Re: [I] [Feature Request]: allow consistent slog redirects [beam] via GitHub
  • Re: [I] [Feature Request]: allow consistent slog redirects [beam] via GitHub
• [PR] Address no-access pyrefly error [beam] via GitHub
  • Re: [PR] Address no-access pyrefly error [beam] via GitHub
  • Re: [PR] Address no-access pyrefly error [beam] via GitHub
• Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] via GitHub
• Re: [I] DebeziumIO cannot connect to cloud Postgres instances [beam] via GitHub
  • Re: [I] DebeziumIO cannot connect to cloud Postgres instances [beam] via GitHub
• Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] via GitHub
• Re: [I] Matcher(s) for TableRow [beam] via GitHub
• Re: [I] [Task]: Upgrade avro to the latest version after Java 8 is deprecated [beam] via GitHub
• [PR] Fixes broken URLs in example notebooks [beam] via GitHub
  • Re: [PR] Fixes broken URLs in example notebooks [beam] via GitHub
• [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] via GitHub
  • Re: [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] via GitHub
  • Re: [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] via GitHub
• [I] [Task]: Getting started - Interactive Overview broken notebook URLs [beam] via GitHub
  • Re: [I] [Task]: Getting started - Interactive Overview broken notebook URLs [beam] via GitHub
• [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
  • Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
  • Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
  • Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
• [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
• [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] via GitHub
  • Re: [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] via GitHub
  • Re: [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] via GitHub
• [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
• [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
  • Re: [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
  • Re: [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
  • Re: [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
• [PR] Update Beam website to release 2.72.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.72.0 [beam] via GitHub
• Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] via GitHub
• Re: [I] Globbing asterisk cannot be escaped in file reads. [beam] via GitHub
• Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] via GitHub
• [PR] Adding "new metadata" skill [beam] via GitHub
  • Re: [PR] Adding "new metadata" skill [beam] via GitHub
  • Re: [PR] Adding "new metadata" skill [beam] via GitHub
• [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
  • Re: [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
  • Re: [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
• Re: [I] [Bug]: Latest version (2.57) version of apache beam java sdk has dependecy on an old version of mongo driver (3.12) [beam] via GitHub
• Re: [I] Handling the restart with apache beam debezium application [beam] via GitHub
• [PR] ci: update build configuration [beam] via GitHub
  • Re: [PR] ci: update build configuration [beam] via GitHub
  • Re: [PR] closed [beam] via GitHub
• Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
• [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
  • Re: [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
  • Re: [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
  • Re: [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
• [PR] Cherrypick #37850 [beam] via GitHub
  • Re: [PR] Cherrypick #37850 [beam] via GitHub
  • Re: [PR] Cherrypick #37850 [beam] via GitHub
  • Re: [PR] Cherrypick #37850 [beam] via GitHub
• [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
• [I] [Bug]: [Python] Union of named fields loss fields after GBK [beam] via GitHub
  • Re: [I] [Bug]: [Python] Union of named fields loss fields after GBK [beam] via GitHub
• [I] [Feature Request]: Support for inferring schemas from Python dataclasses [beam] via GitHub
  • Re: [I] [Feature Request]: Support for inferring schemas from Python dataclasses [beam] via GitHub
• Re: [I] TextIO.write .withWindowedWrites does not work on windows [beam] via GitHub
• Re: [I] [GSOC 25] Enhanced Interactive Pipeline Development Environment for JupyterLab [beam] via GitHub
• Re: [I] [Feature Request]: Implement Native Java Remote Inference [beam] via GitHub
• Re: [PR] Include logger name in FnApiLogRecordHandler log entries [beam] via GitHub
• [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
• [PR] Pin zookeeper in expansion service [beam] via GitHub
  • Re: [PR] Pin zookeeper in expansion service [beam] via GitHub
  • Re: [PR] Pin zookeeper in expansion service [beam] via GitHub
  • Re: [PR] Pin zookeeper in expansion service [beam] via GitHub
• [I] The Python Cost Benchmarks Dataflow job is flaky [beam] via GitHub
• Re: [I] [Feature Request]: Add integer and string _id keys support to Java IO MongoDB [beam] via GitHub
• Re: [I] [Bug]: Schema inference is non-deterministic [beam] via GitHub
• [PR] Fix #37833: Use named logger instead of root logger in transforms/util.py [beam] via GitHub
  • Re: [PR] Fix #37833: Use named logger instead of root logger in transforms/util.py [beam] via GitHub
  • Re: [PR] Fix #37833: Use named logger instead of root logger in transforms/util.py [beam] via GitHub
  • Re: [PR] Fix #37833: Use named logger instead of root logger in transforms/util.py [beam] via GitHub
• [PR] Revert "upgrade vllm for vuln" [beam] via GitHub
  • Re: [PR] Revert "upgrade vllm for vuln" [beam] via GitHub
  • Re: [PR] Revert "upgrade vllm for vuln" [beam] via GitHub
  • Re: [PR] Revert "upgrade vllm for vuln" [beam] via GitHub
  • Re: [PR] Revert "upgrade vllm for vuln" [beam] via GitHub
• [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
  • Re: [PR] Handle some cases during infer schema from dataclass [beam] via GitHub
• [I] [Task]: Beam tft extra depends on old version of tensorflow-transform that requires protobuf v4. [beam] via GitHub
• [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
  • Re: [PR] Update python dev container tag [beam] via GitHub
• [PR] [typescript] - fix rest of vulnerabilities [beam] via GitHub
  • Re: [PR] [typescript] - fix rest of vulnerabilities [beam] via GitHub
  • Re: [PR] [typescript] - fix rest of vulnerabilities [beam] via GitHub
  • Re: [PR] [typescript] - fix rest of vulnerabilities [beam] via GitHub
  • Re: [PR] [typescript] - fix rest of vulnerabilities [beam] via GitHub
  • Re: [PR] [typescript] - fix rest of vulnerabilities [beam] via GitHub
• [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
  • Re: [PR] Fixes metadata propagation from doFn output to next parDo by introducing new interface and plumbing propagation [beam] via GitHub
• Re: [I] Support for custom Python UnboundedSource [beam] via GitHub
• [PR] Fix python postcommit 30513 [beam] via GitHub
  • Re: [PR] Fix python postcommit 30513 [beam] via GitHub
  • Re: [PR] Fix python postcommit 30513 [beam] via GitHub
  • Re: [PR] Fix python postcommit 30513 [beam] via GitHub
  • Re: [PR] Fix python postcommit 30513 [beam] via GitHub
  • Re: [PR] Fix python postcommit 30513 [beam] via GitHub
• [PR] Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds [beam] via GitHub
  • Re: [PR] Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds [beam] via GitHub
  • Re: [PR] Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds [beam] via GitHub
  • Re: [PR] Use Python 3.11 and cibuildwheel 3.4.0 for wheel builds [beam] via GitHub

• Earlier messages