github  

Messages by Thread

• • Re: [PR] Add option to use asyncio for AsyncWrapper [beam] via GitHub
  • Re: [PR] Add option to use asyncio for AsyncWrapper [beam] via GitHub
  • Re: [PR] Add option to use asyncio for AsyncWrapper [beam] via GitHub
  • Re: [PR] Add option to use asyncio for AsyncWrapper [beam] via GitHub
• [PR] [Cherry-pick] Update hbase version to fix netty CVEs. (#38241) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Update hbase version to fix netty CVEs. (#38241) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Update hbase version to fix netty CVEs. (#38241) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Update hbase version to fix netty CVEs. (#38241) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Update hbase version to fix netty CVEs. (#38241) [beam] via GitHub
• [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Fix CVE-2026-34477 (#38210) [beam] via GitHub
• [PR] [Cherry-pick] Bump Pytest Bounds (#38218) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Bump Pytest Bounds (#38218) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Bump Pytest Bounds (#38218) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Bump Pytest Bounds (#38218) [beam] via GitHub
  • Re: [PR] [Cherry-pick] Bump Pytest Bounds (#38218) [beam] via GitHub
• [PR] [2.73.0] Cherrypick #38041 [beam] via GitHub
  • Re: [PR] [2.73.0] Cherrypick #38041 [beam] via GitHub
  • Re: [PR] [2.73.0] Cherrypick #38041 [beam] via GitHub
  • Re: [PR] [2.73.0] Cherrypick #38041 [beam] via GitHub
  • Re: [PR] [2.73.0] Cherrypick #38041 [beam] via GitHub
• Re: [PR] Add Pyrefly Check PreCommit [beam] via GitHub
  • Re: [PR] Add Pyrefly Check PreCommit [beam] via GitHub
• Re: [I] [Tracking]: Beam 3.0.0 Milestone 1 Python SDK breaking changes [beam] via GitHub
  • Re: [I] [Tracking]: Beam 3.0.0 Milestone 1 Python SDK breaking changes [beam] via GitHub
• Re: [I] [Task]: Improving Beam Python Typehints [beam] via GitHub
• Re: [I] [Feature Request]: Support generic PTransforms in Python SDK [beam] via GitHub
• Re: [PR] Grpc3 [beam] via GitHub
  • Re: [PR] Grpc3 [beam] via GitHub
  • Re: [PR] Grpc3 [beam] via GitHub
• Re: [I] [Bug]: Inline exception propagation with fused DoFns can lead to unexpected behavior [beam] via GitHub
• Re: [PR] Grpc take 2 [beam] via GitHub
  • Re: [PR] Grpc take 2 [beam] via GitHub
  • Re: [PR] Grpc take 2 [beam] via GitHub
• Re: [PR] Go VR Flink test on Flink 2.0 [beam] via GitHub
  • Re: [PR] Go VR Flink test on Flink 2.0 [beam] via GitHub
• Re: [I] [Task]: Deprecate Jet runner [beam] via GitHub
• Re: [I] [Feature Request]: Add set of ML Beam containers [beam] via GitHub
• Re: [PR] Grpc4 [beam] via GitHub
  • Re: [PR] Grpc4 [beam] via GitHub
  • Re: [PR] Grpc4 [beam] via GitHub
• [PR] Avoid cloning from unstable tox/CI venvs [beam] via GitHub
  • Re: [PR] Avoid cloning from unstable tox/CI venvs [beam] via GitHub
• [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
  • Re: [PR] [ErrorProne] enable AutoValueSubclassLeaked, EscapedEntity, JUnitIncompatibleType, EqualsUnsafeCast [beam] via GitHub
• [PR] [Spark Runner] Add Spark 4 runner (slim, override-only) [beam] via GitHub
  • Re: [PR] [Spark Runner] Add Spark 4 runner (slim, override-only) [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [WIP] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [Runner] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
  • Re: [PR] [runners-spark] Add Spark 4 runner [beam] via GitHub
• [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
  • Re: [PR] fix pipeline result naming inconsistency in Dataflow runner [beam] via GitHub
• [PR] Fix Clean Up GCP Resources job [beam] via GitHub
  • Re: [PR] Fix Clean Up GCP Resources job [beam] via GitHub
  • Re: [PR] Fix Clean Up GCP Resources job [beam] via GitHub
• [PR] Fix/add experiment refactor [beam] via GitHub
  • Re: [PR] Fix/add experiment refactor [beam] via GitHub
  • Re: [PR] Fix/add experiment refactor [beam] via GitHub
  • Re: [PR] Fix/add experiment refactor [beam] via GitHub
• [I] [Feature Request]: Add a Variant type to Beam Schemas [beam] via GitHub
• [PR] Cherrypick #38132 Retry transient NOT_FOUND on Storage API default stream [beam] via GitHub
  • Re: [PR] Cherrypick #38132 Retry transient NOT_FOUND on Storage API default stream [beam] via GitHub
  • Re: [PR] Cherrypick #38132 Retry transient NOT_FOUND on Storage API default stream [beam] via GitHub
  • Re: [PR] Cherrypick #38132 Retry transient NOT_FOUND on Storage API default stream [beam] via GitHub
• [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
  • Re: [PR] Add connectivity type tracking to endpoint consumption logic [beam] via GitHub
• Re: [I] Coder encode/decode context documentation is lacking [beam] via GitHub
• Re: [I] [Bug]: No parallelization for ReadFromParquet (or any Python Read transforms) in Spark RDD Runner [beam] via GitHub
• [PR] Remove widget state data in run_inference_gemma.ipynb [beam] via GitHub
  • Re: [PR] Remove widget state data in run_inference_gemma.ipynb [beam] via GitHub
  • Re: [PR] Remove widget state data in run_inference_gemma.ipynb [beam] via GitHub
  • Re: [PR] Remove widget state data in run_inference_gemma.ipynb [beam] via GitHub
  • Re: [PR] Remove widget state data in run_inference_gemma.ipynb [beam] via GitHub
• Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
• [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam] via GitHub
• Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] via GitHub
  • Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] via GitHub
• Re: [I] [Disabled Test]: :runners:spark:3:test ResumeFromCheckpointStreamingTest testWithResume is disabled due to flake rate [beam] via GitHub
  • Re: [I] [Disabled Test]: :runners:spark:3:test ResumeFromCheckpointStreamingTest testWithResume is disabled due to flake rate [beam] via GitHub
• Re: [I] [Bug]: Incorrect $partition Metadata in Trino for Iceberg Tables Written via IcebergIO.writeRows with Timestamp Partitioning [beam] via GitHub
  • Re: [I] [Bug]: Incorrect $partition Metadata in Trino for Iceberg Tables Written via IcebergIO.writeRows with Timestamp Partitioning [beam] via GitHub
• Re: [I] [Bug]: Do not expose logging apis in beam/log [beam] via GitHub
  • Re: [I] [Bug]: Do not expose logging apis in beam/log [beam] via GitHub
• Re: [PR] Fix triggering frequency documentation validation [beam] via GitHub
  • Re: [PR] Fix triggering frequency documentation validation [beam] via GitHub
  • Re: [PR] Fix triggering frequency documentation validation [beam] via GitHub
• [PR] Enhance documentation for stateful conversations [beam] via GitHub
  • Re: [PR] Enhance documentation for stateful conversations [beam] via GitHub
  • Re: [PR] Enhance documentation for stateful conversations [beam] via GitHub
  • Re: [PR] Enhance documentation for stateful conversations [beam] via GitHub
  • Re: [PR] Enhance documentation for stateful conversations [beam] via GitHub
  • Re: [PR] Enhance documentation for stateful conversations [beam] via GitHub
  • Re: [PR] Enhance documentation for stateful conversations [beam] via GitHub
• [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
  • Re: [PR] Fix: Correct portability_worker_id for child process logs in Python SDK harness [beam] via GitHub
• [PR] introduce private method to remove clones [beam] via GitHub
  • Re: [PR] introduce private method to remove clones [beam] via GitHub
  • Re: [PR] introduce private method to remove clones [beam] via GitHub
  • Re: [PR] introduce private method to remove clones [beam] via GitHub
• [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
  • Re: [PR] [Enrichment] Expose max_batch_duration_secs in SQL/BQ handlers (#38243) [beam] via GitHub
• [I] [Bug]: Python Enrichment BigQuery handler does not expose `max_batch_duration_secs` to `BatchElements` [beam] via GitHub
  • Re: [I] [Bug]: Python Enrichment BigQuery handler does not expose `max_batch_duration_secs` to `BatchElements` [beam] via GitHub
• Re: [I] [Bug]: Cannot read from ssl-enabled cassandra cluster [beam] via GitHub
  • Re: [I] [Bug]: Cannot read from ssl-enabled cassandra cluster [beam] via GitHub
• Re: [I] [Bug]: Prism's handling of side inputs could fail sometime [beam] via GitHub
  • Re: [I] [Bug]: Prism's handling of side inputs could fail sometime [beam] via GitHub
• Re: [I] [Failing Test]: `MLTest.test_ml_preprocessing_yaml` is flaky [beam] via GitHub
• [PR] Fix non-unique job names in TextIOReadTest [beam] via GitHub
  • Re: [PR] Fix non-unique job names in TextIOReadTest [beam] via GitHub
  • Re: [PR] Fix non-unique job names in TextIOReadTest [beam] via GitHub
  • Re: [PR] Fix non-unique job names in TextIOReadTest [beam] via GitHub
  • Re: [PR] Fix non-unique job names in TextIOReadTest [beam] via GitHub
  • Re: [PR] Fix non-unique job names in TextIOReadTest [beam] via GitHub

• Earlier messages
• Later messages