github  

Messages by Thread

• [I] [Feature Request]: add Milvus Search Enrichment Handler Examples and update the Beam website [beam] via GitHub
  • Re: [I] [Feature Request]: add Milvus Search Enrichment Handler Examples and update the Beam website [beam] via GitHub
• [PR] workflows: Add `ubuntu-latest` to `beam_PreCommit_Python_Examples` workflow and trigger `require_docker_in_docker` tests [beam] via GitHub
  • Re: [PR] workflows: Add `ubuntu-latest` to `beam_PreCommit_Python_Examples` workflow and trigger `require_docker_in_docker` tests [beam] via GitHub
• [PR] docs(downloads): update source code download links to use closer mirror [beam] via GitHub
  • Re: [PR] docs(downloads): update source code download links to use closer mirror [beam] via GitHub
• Re: [PR] Bump codecov/codecov-action from 3 to 5 [beam] via GitHub
  • Re: [PR] Bump codecov/codecov-action from 3 to 5 [beam] via GitHub
• [I] [Tracking]: Beam 3.0.0 - Milestone 1 Key Features [beam] via GitHub
• Re: [PR] Move Vertex LLM Inference IT Test to new Endpoint [beam] via GitHub
• Re: [I] [Feature Request]: Support streaming inserts for bounded PCollections [beam] via GitHub
• Re: [I] [Task]: Upgrade gcs-connector libraries to 3.x [beam] via GitHub
• Re: [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
  • Re: [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
  • Re: [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
  • Re: [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
• Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] via GitHub
  • Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] via GitHub
• [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse proto builders on hot path to reduce GC overhead [beam] via GitHub
• [PR] [Prism] Fix potential side-effect in TriggerAfterEach.onFire. [beam] via GitHub
• [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
• [PR] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
  • Re: [PR] [Prism] Defer unlocking to avoid deadlock [beam] via GitHub
• [PR] Bump transformers from 4.30.0 to 4.53.0 in /sdks/python/apache_beam/ml/inference [beam] via GitHub
  • Re: [PR] Bump transformers from 4.30.0 to 4.53.0 in /sdks/python/apache_beam/ml/inference [beam] via GitHub
• Re: [PR] Bump transformers from 4.30.0 to 4.48.0 in /sdks/python/apache_beam/ml/inference [beam] via GitHub
• Re: [I] [Feature Request]: Set option for acknowledge the messages in PulsarIO reader [beam] via GitHub
• Re: [I] [Feature Request]: Make Pulsar IO connector publish messages asynchronously [beam] via GitHub
  • Re: [I] [Feature Request]: Make Pulsar IO connector publish messages asynchronously [beam] via GitHub
• [PR] Add blog post for Google Summer of Code 25 on improving Apache Beam's infrastructure [beam] via GitHub
  • Re: [PR] Add blog post for Google Summer of Code 25 on improving Apache Beam's infrastructure [beam] via GitHub
  • Re: [PR] Add blog post for Google Summer of Code 25 on improving Apache Beam's infrastructure [beam] via GitHub
  • Re: [PR] Add blog post for Google Summer of Code 25 on improving Apache Beam's infrastructure [beam] via GitHub
• [PR] Bump google-github-actions/auth from 2 to 3 [beam] via GitHub
  • Re: [PR] Bump google-github-actions/auth from 2 to 3 [beam] via GitHub
• [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] via GitHub
  • Re: [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] via GitHub
  • Re: [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] via GitHub
  • Re: [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] via GitHub
  • Re: [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] via GitHub
  • Re: [PR] Use distroless container built from HEAD in Dataflow V2 integration tests [beam] via GitHub
• Re: [I] [Feature Request]: Support returning back BoundedTrie in metric result [beam] via GitHub
• Re: [I] [Bug]: PulsarIO write() complains of missing ClientUrl even when provided with withClientUrl [beam] via GitHub
• Re: [I] org.apache.beam.sdk.io.pulsar.PulsarIOTest.testReadFromSimpleTopic flaky [beam] via GitHub
• Re: [I] PulsarIOTest.testReadFromSimpleTopic is very flaky [beam] via GitHub
• Re: [I] [Bug]: PulsarIO.read() is failing with java.lang.RuntimeException: Could not find a way to create AutoValue class class com.idfy.beam.pulsar.PulsarSourceDescriptor [beam] via GitHub
• [PR] Add dill dep where tensorflow-transform is used. [beam] via GitHub
  • Re: [PR] Add dill dep where tensorflow-transform is used. [beam] via GitHub
  • Re: [PR] Add dill dep where tensorflow-transform is used. [beam] via GitHub
  • Re: [PR] Add dill dep where tensorflow-transform is used. [beam] via GitHub
• [PR] Bump docker/build-push-action from 4 to 6 [beam] via GitHub
  • Re: [PR] Bump docker/build-push-action from 4 to 6 [beam] via GitHub
  • Re: [PR] Bump docker/build-push-action from 4 to 6 [beam] via GitHub
• [PR] Bump actions/github-script from 7 to 8 [beam] via GitHub
  • Re: [PR] Bump actions/github-script from 7 to 8 [beam] via GitHub
• Re: [PR] Set selected library to default before checks [beam] via GitHub
  • Re: [PR] Set selected library to default before checks [beam] via GitHub
• [PR] Bump actions/download-artifact from 4 to 5 [beam] via GitHub
  • Re: [PR] Bump actions/download-artifact from 4 to 5 [beam] via GitHub
• [PR] Bump actions/stale from 9 to 10 [beam] via GitHub
  • Re: [PR] Bump actions/stale from 9 to 10 [beam] via GitHub
• [PR] Bump actions/checkout from 4 to 5 [beam] via GitHub
  • Re: [PR] Bump actions/checkout from 4 to 5 [beam] via GitHub
• Re: [I] [Bug]: download page problems [beam] via GitHub
  • Re: [I] [Bug]: download page problems [beam] via GitHub
  • Re: [I] [Bug]: download page problems [beam] via GitHub
  • Re: [I] [Bug]: download page problems [beam] via GitHub
• Re: [I] The PerformanceTests PubsubIOIT Python Streaming job is flaky [beam] via GitHub
• [PR] Allow dependabot to update all actions [beam] via GitHub
  • Re: [PR] Allow dependabot to update all actions [beam] via GitHub
  • Re: [PR] Allow dependabot to update all actions [beam] via GitHub
  • Re: [PR] Allow dependabot to update all actions [beam] via GitHub
• Re: [I] [Feature Request]: `kms_key` should be used in making `temp_dataset`'s. [beam] via GitHub
• Re: [PR] raise errors instead of warnings for no iterators [beam] via GitHub
• [PR] Fix PostCommit Python ValidatesRunner Dataflow job [beam] via GitHub
  • Re: [PR] Fix PostCommit Python ValidatesRunner Dataflow job [beam] via GitHub
  • Re: [PR] Fix PostCommit Python ValidatesRunner Dataflow job [beam] via GitHub
  • Re: [PR] Fix PostCommit Python ValidatesRunner Dataflow job [beam] via GitHub
• [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
  • Re: [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
  • Re: [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
  • Re: [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
• [PR] Update dill requirement from <0.3.2,>=0.3.1.1 to >=0.3.1.1,<0.4.1 in /sdks/python [beam] via GitHub
  • Re: [PR] Update dill requirement from <0.3.2,>=0.3.1.1 to >=0.3.1.1,<0.4.1 in /sdks/python [beam] via GitHub
• [PR] Fix TriggerAlways integration test. [beam] via GitHub
  • Re: [PR] [Prism] Disable combiner lifting for TriggerAlways [beam] via GitHub
  • Re: [PR] [Prism] Disable combiner lifting for TriggerAlways [beam] via GitHub
• [PR] Bump org.apache.maven.plugins:maven-surefire-plugin from 3.5.3 to 3.5.4 [beam-starter-java] via GitHub
• [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] via GitHub
  • Re: [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] via GitHub
  • Re: [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] via GitHub
  • Re: [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] via GitHub
  • Re: [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] via GitHub
• Re: [I] [Feature Request]: Fully Support Type Checking Callables [beam] via GitHub
• [I] The PostCommit Python ValidatesRunner Dataflow job is flaky [beam] via GitHub
• Re: [PR] feat(bigquery): add GEOGRAPHY type support for BigQuery I/O [beam] via GitHub
  • Re: [PR] feat(bigquery): add GEOGRAPHY type support for BigQuery I/O [beam] via GitHub
  • Re: [PR] feat(bigquery): add GEOGRAPHY type support for BigQuery I/O [beam] via GitHub
• Re: [PR] Sort output before comparison in enrichment test [beam] via GitHub
  • Re: [PR] Sort output before comparison in enrichment test [beam] via GitHub
• [PR] [yaml] - add yaml top level keys test [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
  • Re: [PR] [yaml] - add yaml expand_pipeline ut tests [beam] via GitHub
• Re: [I] [Feature Request]: Add support for `GEOGRAPHY` data type in BigQuery Storge Write API in Python [beam] via GitHub
• Re: [I] Bug in Python SDK-s Enrichment transform client side throttling [beam] via GitHub
• Re: [I] [prism] Support Custom WindowFns [beam] via GitHub
• Re: [PR] Return inputwatermarkAdvanced signal and use it in bundleReady [beam] via GitHub
• [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
  • Re: [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
  • Re: [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
  • Re: [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
  • Re: [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
  • Re: [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
• Re: [I] [Task]: Fill Runner Metrics support gap in Sources [beam] via GitHub
• [PR] Fix extra on-time pane fired at non-after-watermark triggers. [beam] via GitHub
  • Re: [PR] Fix extra on-time pane fired at non-after-watermark triggers. [beam] via GitHub
  • Re: [PR] Fix extra on-time pane fired at non-after-watermark triggers. [beam] via GitHub
  • Re: [PR] Fix extra on-time pane fired at non-after-watermark triggers. [beam] via GitHub
  • Re: [PR] Fix extra on-time pane fired at non-after-watermark triggers. [beam] via GitHub
• [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
  • Re: [PR] Fix PulsarIO [beam] via GitHub
• [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
  • Re: [PR] fix(pubsub): handle pubsub message attributes correctly in write [beam] via GitHub
• [PR] Managed Bigquery Java Read&Write Transforms [beam] via GitHub
  • Re: [PR] Managed Bigquery Java Read&Write Transforms [beam] via GitHub
  • Re: [PR] Managed Bigquery Java Read&Write Transforms [beam] via GitHub
• [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
  • Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
  • Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
  • Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
  • Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
  • Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• [PR] Add preRefreshedInput watermark and use it in bundleReady. [beam] via GitHub
  • Re: [PR] Add preRefreshedInput watermark and use it in bundleReady. [beam] via GitHub
  • Re: [PR] Add preRefreshedInput watermark and use it in bundleReady. [beam] via GitHub
  • Re: [PR] Add preRefreshedInput watermark and use it in bundleReady. [beam] via GitHub
  • Re: [PR] Add preRefreshedInput watermark and use it in bundleReady. [beam] via GitHub
  • Re: [PR] [Prism] Add previousInput watermark and use it in bundleReady [beam] via GitHub
  • Re: [PR] [Prism] Add previousInput watermark and use it in bundleReady [beam] via GitHub
• Re: [PR] [IcebergIO] pin ORC 1.9.6 [beam] via GitHub
  • Re: [PR] [IcebergIO] pin ORC 1.9.6 [beam] via GitHub
  • Re: [PR] [IcebergIO] pin ORC 1.9.6 [beam] via GitHub
• [PR] Update Beam website to release 2.68.0 [beam] via GitHub
• [PR] Fix ml gradle [beam] via GitHub
  • Re: [PR] Fix ml gradle [beam] via GitHub
• [PR] [CP] Fix ml gradle (#36134) [beam] via GitHub
  • Re: [PR] [CP] Fix ml gradle (#36134) [beam] via GitHub
• [PR] Update action [beam] via GitHub
  • Re: [PR] Update action [beam] via GitHub
  • Re: [PR] Update action [beam] via GitHub
• Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] via GitHub
• [PR] Update import gpg action [beam] via GitHub
  • Re: [PR] Update import gpg action [beam] via GitHub
  • Re: [PR] Update import gpg action [beam] via GitHub
• [PR] Fix flaky GrpcDirectGetWorkStreamTest.testConsumedWorkItems_itemsSplitAcrossResponses [beam] via GitHub
• [PR] Update PubsubIO.java documentation [beam] via GitHub
  • Re: [PR] Update PubsubIO.java documentation [beam] via GitHub
  • Re: [PR] Update PubsubIO.java documentation [beam] via GitHub
• [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub
  • Re: [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub

• Earlier messages