github  

Messages by Date

• 2026/04/24 Re: [PR] Use Flink 2.0 for load tests [beam] via GitHub
• 2026/04/24 Re: [PR] bump beam container versions [beam] via GitHub
• 2026/04/24 [PR] bump beam container versions [beam] via GitHub
• 2026/04/24 Re: [PR] Fix serial warning in starter and example archetypes [beam] via GitHub
• 2026/04/24 Re: [PR] Go validation runner test script fixes [beam] via GitHub
• 2026/04/24 Re: [PR] FileBasedSinkTest failure [beam] via GitHub
• 2026/04/24 Re: [PR] [runners-spark] Use robust constructor resolution in EncoderFactory [beam] via GitHub
• 2026/04/24 Re: [PR] FileBasedSinkTest failure [beam] via GitHub
• 2026/04/24 [PR] FileBasedSinkTest failure [beam] via GitHub
• 2026/04/24 Re: [PR] Bump ray from 2.54.0 to 2.55.0 in /sdks/python/container/ml/py311 [beam] via GitHub
• 2026/04/24 Re: [PR] [runners-spark] Use robust constructor resolution in EncoderFactory [beam] via GitHub
• 2026/04/24 Re: [PR] Go validation runner test script fixes [beam] via GitHub
• 2026/04/24 Re: [PR] Go validation runner test script fixes [beam] via GitHub
• 2026/04/24 [PR] Go validation runner test script fixes [beam] via GitHub
• 2026/04/24 Re: [PR] Fix serial warning in starter and example archetypes [beam] via GitHub
• 2026/04/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/04/24 [I] [Task]: Remove support of Samza runner in new Beam versions [beam] via GitHub
• 2026/04/24 Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
• 2026/04/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/04/24 Re: [PR] Update managed-io.md for release 2.73.0-RC1 [beam] via GitHub
• 2026/04/24 Re: [PR] [WIP][runners-spark] Use robust constructor resolution in EncoderFactory [beam] via GitHub
• 2026/04/24 Re: [PR] [WIP][runners-spark] Use robust constructor resolution in EncoderFactory [beam] via GitHub
• 2026/04/24 Re: [PR] Bump Java bytecode compatibility version to Java11 [beam] via GitHub
• 2026/04/24 Re: [PR] Bump jackson_version - Fix GHSA-72hv-8253-57qq [beam] via GitHub
• 2026/04/24 Re: [PR] Bump jackson_version - Fix GHSA-72hv-8253-57qq [beam] via GitHub
• 2026/04/24 Re: [PR] Bump jackson_version - Fix GHSA-72hv-8253-57qq [beam] via GitHub
• 2026/04/24 Re: [PR] Fix data race in JsonPayloadSerializerProvider. [beam] via GitHub
• 2026/04/24 Re: [PR] Fix data race in JsonPayloadSerializerProvider. [beam] via GitHub
• 2026/04/24 [PR] Bump ray from 2.54.0 to 2.55.0 in /sdks/python/container/ml/py311 [beam] via GitHub
• 2026/04/24 Re: [PR] [BigQueryIO] Include insert error in log message if TableRow parsing fails [beam] via GitHub
• 2026/04/24 Re: [PR] Add PreCommit Java Dataflow workflow (#38094) [beam] via GitHub
• 2026/04/24 Re: [I] [Failing Test]: long running StreamingDataflowWorkerTest [beam] via GitHub
• 2026/04/24 Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
• 2026/04/24 Re: [PR] Remove Samza runner support [beam] via GitHub
• 2026/04/24 Re: [PR] Remove Samza runner support [beam] via GitHub
• 2026/04/24 Re: [PR] SQL DDL documentation [beam] via GitHub
• 2026/04/24 Re: [I] [Bug]: Failing HL7v2IO Integration Test when upgrading BOM [beam] via GitHub
• 2026/04/24 Re: [I] [Bug]: Failing HL7v2IO Integration Test when upgrading BOM [beam] via GitHub
• 2026/04/24 Re: [I] [Tracking]: Performance issue of PubSubIO on non-Dataflow runner [beam] via GitHub
• 2026/04/24 Re: [I] [Bug]: Type hints lost in core transforms [beam] via GitHub
• 2026/04/24 Re: [I] [Bug]: Pass project-id to BigQuery Client in Beam Python SDK [beam] via GitHub
• 2026/04/24 Re: [I] [Feature Request]: Add support for pyarrow >= 19.0.0 [beam] via GitHub
• 2026/04/24 Re: [I] [Bug]: PubsubUnboundedSink not following 1000 messages per batch limit [beam] via GitHub
• 2026/04/24 Re: [I] [Feature Request]: Propagate drain mode up to reduceFn [beam] via GitHub
• 2026/04/24 Re: [PR] [Python] Deprecate native SpannerIO implementation (#35860) [beam] via GitHub
• 2026/04/24 Re: [PR] [Python] Deprecate native SpannerIO implementation (#35860) [beam] via GitHub
• 2026/04/24 Re: [PR] Snowflake bounded source [beam] via GitHub
• 2026/04/24 Re: [PR] Snowflake bounded source [beam] via GitHub
• 2026/04/24 Re: [PR] feat(io): Implement parallel reading in SparkReceiverIO (Fixes #37410) [beam] via GitHub
• 2026/04/24 Re: [PR] Bump transformers from 4.55.4 to 5.0.0rc3 in /sdks/python/container/ml/py312 [beam] via GitHub
• 2026/04/24 Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
• 2026/04/24 Re: [PR] Update managed-io.md for release 2.73.0-RC1 [beam] via GitHub
• 2026/04/24 Re: [PR] Fix RequestResponseIO parseAndThrow to preserve retryable exception types [beam] via GitHub
• 2026/04/24 Re: [PR] Bump keras from 3.12.1 to 3.13.2 in /sdks/python/container/ml/py310 [beam] via GitHub
• 2026/04/24 Re: [PR] [Java SDK] Warn when ValueState contains collection types [beam] via GitHub
• 2026/04/24 Re: [PR] support generics in from row and to row conversions [beam] via GitHub
• 2026/04/24 Re: [PR] [Go SDK] Add GroupIntoBatches transform (#19868) [beam] via GitHub
• 2026/04/24 Re: [PR] [Java]Fix infinite retry issue in BigQuery getDatasetLocation() for non-existent datasets [beam] via GitHub
• 2026/04/24 Re: [PR] SQL DDL documentation [beam] via GitHub
• 2026/04/24 Re: [PR] RedisIO support PCollection of <byte[], byte[]> [beam] via GitHub
• 2026/04/24 Re: [PR] Bump torch from 2.7.1 to 2.8.0 in /sdks/python/container/ml/py312 [beam] via GitHub
• 2026/04/24 Re: [PR] Bump minimatch in /scripts/ci/pr-bot [beam] via GitHub
• 2026/04/24 Re: [PR] Migrate to Google Cloud Dataflow Client [beam] via GitHub
• 2026/04/24 Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
• 2026/04/24 Re: [PR] Bump jackson_version - Fix GHSA-72hv-8253-57qq [beam] via GitHub
• 2026/04/24 Re: [PR] [ErrorProne] Update comment in BeamModulePlugin.groovy [beam] via GitHub
• 2026/04/24 Re: [PR] [ErrorProne] Update comment in BeamModulePlugin.groovy [beam] via GitHub
• 2026/04/24 [PR] [ErrorProne] Update comment in BeamModulePlugin.groovy [beam] via GitHub
• 2026/04/24 Re: [PR] [ErrorProne] enable ClassInitializationDeadlock, Finalize, NullableTypeParameter, ThreadPriorityCheck [beam] via GitHub
• 2026/04/23 Re: [PR] [WIP] BatchElements Transfrom for Java SDK [beam] via GitHub
• 2026/04/23 [PR] [WIP] BatchElements Transfrom for Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/23 Re: [PR] improve Maven badge readability in README [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] Allow SpannerIO.readChangeStream() to query & union a list of change stream TVF's [beam] via GitHub
• 2026/04/23 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub
• 2026/04/23 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub
• 2026/04/23 Re: [PR] Add DiskProvisionedIops and DiskProvisionedThroughputMibps pipeline options [beam] via GitHub
• 2026/04/23 Re: [PR] Add DiskProvisionedIops and DiskProvisionedThroughputMibps pipeline options [beam] via GitHub
• 2026/04/23 Re: [PR] Add DiskProvisionedIops and DiskProvisionedThroughputMibps pipeline options [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] Update Flink Version Compatibility [beam] via GitHub
• 2026/04/23 Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
• 2026/04/23 Re: [PR] Use Flink 2.0 for load tests [beam] via GitHub
• 2026/04/23 [PR] Use Flink 2.0 for load tests [beam] via GitHub
• 2026/04/23 Re: [PR] Make Beartype use the default behavior in is_consistent_with() [beam] via GitHub
• 2026/04/23 Re: [PR] Fix IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] valuekind [beam] via GitHub
• 2026/04/23 [PR] valuekind [beam] via GitHub
• 2026/04/23 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/23 Re: [PR] Update Flink Version Compatibility [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s to fix Flaky Tests [beam] via GitHub
• 2026/04/23 [PR] Update Flink Version Compatibility [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] [ErrorProne] enable ClassInitializationDeadlock, Finalize, NullableTypeParameter, ThreadPriorityCheck [beam] via GitHub
• 2026/04/23 Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] Update managed-io.md for release 2.73.0-RC2 [beam] via GitHub
• 2026/04/23 [PR] Update managed-io.md for release 2.73.0-RC2 [beam] via GitHub
• 2026/04/23 Re: [PR] remove processContext usage across examples (java and kotlin) [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/23 Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
• 2026/04/23 Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] Make Beartype use the default behavior in is_consistent_with() [beam] via GitHub
• 2026/04/23 Re: [PR] Make Beartype use the default behavior in is_consistent_with() [beam] via GitHub
• 2026/04/23 [PR] Make Beartype use the default behavior in is_consistent_with() [beam] via GitHub
• 2026/04/23 Re: [PR] Cherrypick #37815 ClickHouseIO - Improve user agent [beam] via GitHub
• 2026/04/23 Re: [PR] Make Beartype use the default behavior in is_consistent_with() [beam] via GitHub
• 2026/04/23 Re: [PR] [IcebergIO] Support hash distribution mode when writing rows [beam] via GitHub
• 2026/04/23 Re: [PR] Bump requests from 2.32.4 to 2.33.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] via GitHub
• 2026/04/23 Re: [PR] [IcebergIO] Support hash distribution mode when writing rows [beam] via GitHub
• 2026/04/23 [PR] Cherrypick #37815 ClickHouseIO - Improve user agent [beam] via GitHub
• 2026/04/23 Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
• 2026/04/23 Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
• 2026/04/23 Re: [PR] [Cherry-pick] Update hbase version to fix netty CVEs. (#38241) [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s to fix Flaky Tests [beam] via GitHub
• 2026/04/23 Re: [I] [prism] Programmatic Cancel, and Drain [beam] via GitHub
• 2026/04/23 Re: [I] [Bug]: SparkRunner log plumbing for Python SDK not working properly [beam] via GitHub
• 2026/04/23 Re: [I] [Feature Request]: auto-detect schema in managed I/O [beam] via GitHub
• 2026/04/23 Re: [I] [Feature Request]: auto-detect schema in managed I/O [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s to fix Flaky Tests [beam] via GitHub
• 2026/04/23 Re: [PR] [runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s to fix Flaky Tests [beam] via GitHub
• 2026/04/23 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2026/04/23 Re: [PR] [Bug] Fix PubsubUnboundedSink not following 1000 messages per batch limit [beam] via GitHub
• 2026/04/23 Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
• 2026/04/23 Re: [PR] Add Python example for schema transforms (field selection) [beam] via GitHub
• 2026/04/23 Re: [PR] Bump requests from 2.32.4 to 2.33.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing [beam] via GitHub
• 2026/04/23 Re: [PR] improve Maven badge readability in README [beam] via GitHub
• 2026/04/23 Re: [PR] Added a descriptive message tell about status badges [beam] via GitHub
• 2026/04/23 Re: [PR] Fix IndexError in `apache_beam.utils.processes` when pip subprocess fails with short command [beam] via GitHub
• 2026/04/23 Re: [PR] [IcebergIO] Support hash distribution mode when writing rows [beam] via GitHub
• 2026/04/23 Re: [PR] [Java IO] Add ArrowFlight IO connector [beam] via GitHub
• 2026/04/23 Re: [PR] [yaml] - add Reshuffle transform and a test [beam] via GitHub
• 2026/04/23 Re: [PR] [WIP][runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s [beam] via GitHub
• 2026/04/23 [PR] [WIP][runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s [beam] via GitHub
• 2026/04/23 Re: [PR] [Drain] Support extensible element metadata propagation in ReduceFnRunner [beam] via GitHub
• 2026/04/23 Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
• 2026/04/23 [PR] [WIP][runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] [WIP][runners-flink] Use index-based version comparison in flink_runner.gradle [beam] via GitHub
• 2026/04/23 Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
• 2026/04/23 Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
• 2026/04/23 Re: [PR] [WIP][runners-spark] Use robust constructor resolution in EncoderFactory [beam] via GitHub
• 2026/04/23 [PR] [WIP][runners-spark] Use robust constructor resolution in EncoderFactory [beam] via GitHub
• 2026/04/23 Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
• 2026/04/23 Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
• 2026/04/23 Re: [I] The PreCommit Java job is flaky [beam] via GitHub
• 2026/04/23 Re: [I] The PreCommit Java job is flaky [beam] via GitHub
• 2026/04/22 Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
• 2026/04/22 Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
• 2026/04/22 Re: [PR] [IcebergIO] Support sort order on dynamic table creation [beam] via GitHub
• 2026/04/22 Re: [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] via GitHub
• 2026/04/22 Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
• 2026/04/22 Re: [PR] Add DiskProvisionedIops and DiskProvisionedThroughputMibps pipeline options [beam] via GitHub
• 2026/04/22 [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] via GitHub
• 2026/04/22 Re: [PR] [IcebergIO] Support sort order on dynamic table creation [beam] via GitHub
• 2026/04/22 [PR] [IcebergIO] Support sort order on dynamic table creation [beam] via GitHub
• 2026/04/22 Re: [PR] Add DiskProvisionedIops and DiskProvisionedThroughputMibps pipeline options [beam] via GitHub
• 2026/04/22 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub
• 2026/04/22 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub
• 2026/04/22 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub
• 2026/04/22 Re: [PR] Allow SpannerIO.readChangeStream() to query & union a list of change stream TVF's [beam] via GitHub
• 2026/04/22 Re: [PR] Allow SpannerIO.readChangeStream() to query & union a list of change stream TVF's [beam] via GitHub
• 2026/04/22 Re: [PR] Add DiskProvisionedIops and DiskProvisionedThroughputMibps pipeline options [beam] via GitHub
• 2026/04/22 Re: [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] via GitHub
• 2026/04/22 [I] The PostCommit Java ValidatesRunner Dataflow Streaming job is flaky [beam] via GitHub
• 2026/04/22 Re: [I] The PreCommit Java job is flaky [beam] via GitHub
• 2026/04/22 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/22 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/22 Re: [PR] Bump Java bytecode compatibility version to Java11 [beam] via GitHub
• 2026/04/22 Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
• 2026/04/22 Re: [PR] Fix data race in JsonPayloadSerializerProvider. [beam] via GitHub
• 2026/04/22 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/22 Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
• 2026/04/22 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/22 Re: [PR] Implement pluggable Lineage in Java SDK [beam] via GitHub
• 2026/04/22 Re: [PR] Remove mypy configuration [beam] via GitHub
• 2026/04/22 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/22 Re: [PR] [Drain] Support extensible element metadata propagation in ReduceFnRunner [beam] via GitHub
• 2026/04/22 Re: [PR] [Python] Add PCollection.with_side_outputs for chainable side outputs [beam] via GitHub
• 2026/04/22 [PR] [Python] Add PCollection.with_side_outputs for chainable side outputs [beam] via GitHub
• 2026/04/22 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/22 Re: [PR] [Drain] Support extensible element metadata propagation in ReduceFnRunner [beam] via GitHub
• 2026/04/22 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/22 Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
• 2026/04/22 Re: [PR] Automaticaly update BigQuery table schema when unknown fields are seen. [beam] via GitHub
• 2026/04/22 Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
• 2026/04/22 Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
• 2026/04/22 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub
• 2026/04/22 Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
• 2026/04/22 Re: [PR] [wip] - js2py to mini-racer [beam] via GitHub

• Earlier messages