github  

Messages by Thread

• • Re: [PR] [OpenTelemetry] Add gcp otel auth extension [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add gcp otel auth extension [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add gcp otel auth extension [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add gcp otel auth extension [beam] via GitHub
• [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
  • Re: [PR] [yaml] - mongodb read normalization [beam] via GitHub
• [I] [Feature Request]: add drain() method to PipelineResult [beam] via GitHub
  • Re: [I] [Feature Request]: add drain() method to PipelineResult [beam] via GitHub
• Re: [I] [Failing Test]: Dataflow V2 VR Streaming Flakiness due to timeout close worker pool [beam] via GitHub
  • Re: [I] [Failing Test]: Dataflow V2 VR Streaming Flakiness due to timeout close worker pool [beam] via GitHub
• Re: [I] [Failing Test]: A few failed tests for TestStream with keyed elements [beam] via GitHub
  • Re: [I] [Failing Test]: A few failed tests for TestStream with keyed elements [beam] via GitHub
• Re: [PR] js2py to quickjs [beam] via GitHub
  • Re: [PR] js2py to quickjs [beam] via GitHub
• [I] [Bug]: Fix num_storage_api_streams for batch [beam] via GitHub
  • Re: [I] [Bug]: Fix num_storage_api_streams for batch [beam] via GitHub
• [PR] Jsonpick ver [beam] via GitHub
  • Re: [PR] Jsonpick ver [beam] via GitHub
  • Re: [PR] Jsonpick ver [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
  • Re: [PR] Bump jsonpickle upper bound. [beam] via GitHub
• [PR] [Dataflow Streaming][Multikey] Support MultiKey commits in windmill clients [beam] via GitHub
  • Re: [PR] [Dataflow Streaming][Multikey] Support MultiKey commits in windmill clients [beam] via GitHub
  • Re: [PR] [Dataflow Streaming][Multikey] Support MultiKey commits in windmill clients [beam] via GitHub
  • Re: [PR] [Dataflow Streaming][Multikey] Support MultiKey commits in windmill clients [beam] via GitHub
  • Re: [PR] [Dataflow Streaming][Multikey] Support MultiKey commits in windmill clients [beam] via GitHub
• [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
• Re: [PR] Implement a `Top` partitioner [beam] via GitHub
  • Re: [PR] Implement a `Top` partitioner [beam] via GitHub
• [PR] Updates Beam master container tags for Dataflow [beam] via GitHub
  • Re: [PR] Updates Beam master container tags for Dataflow [beam] via GitHub
  • Re: [PR] Updates Beam master container tags for Dataflow [beam] via GitHub
• [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
• [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
• [I] The Republish Released Docker Images job is flaky [beam] via GitHub
  • Re: [I] The Republish Released Docker Images job is flaky [beam] via GitHub
• [PR] Bump github.com/tetratelabs/wazero from 1.11.0 to 1.12.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/tetratelabs/wazero from 1.11.0 to 1.12.0 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.8 to 1.41.9 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.41.8 to 1.41.9 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.21 to 1.22.22 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.21 to 1.22.22 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.21 to 1.22.22 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.21 to 1.22.22 in /sdks [beam] via GitHub
• [PR] Bump github.com/golang-cz/devslog from 0.0.15 to 0.0.16 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/golang-cz/devslog from 0.0.15 to 0.0.16 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.102.1 to 1.102.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.102.1 to 1.102.2 in /sdks [beam] via GitHub
• [PR] Bump nanasess/setup-chromedriver from 2 to 3 [beam] via GitHub
  • Re: [PR] Bump nanasess/setup-chromedriver from 2 to 3 [beam] via GitHub
• [PR] run setup before release checkout [beam] via GitHub
  • Re: [PR] run setup before release checkout [beam] via GitHub
  • Re: [PR] run setup before release checkout [beam] via GitHub
  • Re: [PR] run setup before release checkout [beam] via GitHub
  • Re: [PR] run setup before release checkout [beam] via GitHub
• [PR] Multikey autofix [beam] via GitHub
  • Re: [PR] [WIP] Multikey [beam] via GitHub
• [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
  • Re: [PR] Add Worker hashes for Golang [beam] via GitHub
• Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] via GitHub
  • Re: [I] Compatibility Issues Between Apache Beam and Flink [beam] via GitHub
• Re: [I] Requesting invitation to ASF Slack Workspace [beam] via GitHub
  • Re: [I] Requesting invitation to ASF Slack Workspace [beam] via GitHub
• Re: [PR] Iceberg CDC streaming source [beam] via GitHub
  • Re: [PR] Iceberg CDC streaming source [beam] via GitHub
  • Re: [PR] Iceberg CDC streaming source [beam] via GitHub
• Re: [I] [Feature Request]: Add Qdrant vector database ingestion support [beam] via GitHub
• Re: [I] WriteToBigQuery in BundleBasedDirectRunner fails when method is FILE_LOADS [beam] via GitHub
  • Re: [I] WriteToBigQuery in BundleBasedDirectRunner fails when method is FILE_LOADS [beam] via GitHub
• Re: [I] [Task]: Update Python slowly updating side input example [beam] via GitHub
• [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
  • Re: [PR] [CI] Stabilize PostCommit Java ValidatesRunner Dataflow Streaming workflow [beam] via GitHub
• [PR] [CI] Fix Playground CI Nightly flakiness caused by API rate limiting and backend startup races [beam] via GitHub
  • Re: [PR] [CI] Fix Playground CI Nightly flakiness caused by API rate limiting and backend startup races [beam] via GitHub
  • Re: [PR] [CI] Fix Playground CI Nightly flakiness caused by API rate limiting and backend startup races [beam] via GitHub
  • Re: [PR] [CI] Fix Playground CI Nightly flakiness caused by API rate limiting and backend startup races [beam] via GitHub
• Re: [I] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [I] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
• [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
• Re: [I] [Feature Request]: Integrate Apache Beam with Open Lineage [beam] via GitHub
• Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] via GitHub
  • Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] via GitHub
  • Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] via GitHub
• [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
  • Re: [PR] [IO] Implement DeltaIO reader and add Delta Lake perf tests [beam] via GitHub
• Re: [I] [Task]: Add perf tests [beam] via GitHub
  • Re: [I] [Task]: Add perf tests [beam] via GitHub
  • Re: [I] [Task]: Add perf tests [beam] via GitHub
  • Re: [I] [Task]: Add perf tests [beam] via GitHub
• [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
  • Re: [PR] [Python] Honor disableCounterMetrics, disableStringSetMetrics, and disableBoundedTrieMetrics experiments [beam] via GitHub
• [PR] Handle empty batches in Python worker counters [beam] via GitHub
  • Re: [PR] Handle empty batches in Python worker counters [beam] via GitHub

• Earlier messages
• Later messages