github  

Messages by Thread

• [PR] Add Python example for slowly updating global window side inputs [beam] via GitHub
• [PR] Remove per-open metadata RPC from BeamBlobReader [beam] via GitHub
• Re: [I] [Task]: Update Python slowly updating side input example [beam] via GitHub
• [PR] [KafkaIO] Add `with_gcp_adc` and `num_partitions` options to Kafka SchemaTransforms and YAML [beam] via GitHub
  • Re: [PR] [KafkaIO] Add `with_gcp_adc` and `num_partitions` options to Kafka SchemaTransforms and YAML [beam] via GitHub
• [PR] Remove upper bound pin for cryptography. [beam] via GitHub
  • Re: [PR] Remove upper bound pin for cryptography. [beam] via GitHub
• [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam] via GitHub
  • Re: [PR] [KafkaIO] Advance idle partition watermark without requiring a record [beam] via GitHub
• [I] [Feature Request]: Allow ADK Model Handler to use local models [beam] via GitHub
• [PR] Extend ADKAgentModelHandler to support deploying local models [beam] via GitHub
  • Re: [PR] Extend ADKAgentModelHandler to support deploying local models [beam] via GitHub
  • Re: [PR] Extend ADKAgentModelHandler to support deploying local models [beam] via GitHub
  • Re: [PR] Extend ADKAgentModelHandler to support deploying local models [beam] via GitHub
  • Re: [PR] Extend ADKAgentModelHandler to support deploying local models [beam] via GitHub
• [PR] [Python] Make cloud storage dependencies optional on import in gcsio and s3io [beam] via GitHub
  • Re: [PR] [Python] Make cloud storage dependencies optional on import in gcsio and s3io [beam] via GitHub
  • Re: [PR] [Python] Make cloud storage dependencies optional on import in gcsio and s3io [beam] via GitHub
  • Re: [PR] [Python] Make cloud storage dependencies optional on import in gcsio and s3io [beam] via GitHub
  • Re: [PR] [Python] Make cloud storage dependencies optional on import in gcsio and s3io [beam] via GitHub
• Re: [I] [Feature Request]: Support for iceberg dynamic destination with varying schema [beam] via GitHub
• [PR] normalize BigQuery CDC [beam] via GitHub
• [I] [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support [beam] via GitHub
  • Re: [I] [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support [beam] via GitHub
  • Re: [I] [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support [beam] via GitHub
  • Re: [I] [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support [beam] via GitHub
• [PR] Bump docker/setup-buildx-action from 4.3.0 to 4.4.0 [beam] via GitHub
  • Re: [PR] Bump docker/setup-buildx-action from 4.3.0 to 4.4.0 [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.7 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.7 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.7 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.5 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.5 in /sdks [beam] via GitHub
• [PR] Bump docker/setup-qemu-action from 4.3.0 to 4.4.0 [beam] via GitHub
  • Re: [PR] Bump docker/setup-qemu-action from 4.3.0 to 4.4.0 [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.4 to 1.20.5 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.4 to 1.20.5 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.4 to 1.20.5 in /sdks [beam] via GitHub
• [PR] Bump google.golang.org/api from 0.297.0 to 0.298.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.297.0 to 0.298.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.297.0 to 0.298.0 in /sdks [beam] via GitHub
• [PR] Bump docker/build-push-action from 7.3.0 to 7.4.0 [beam] via GitHub
  • Re: [PR] Bump docker/build-push-action from 7.3.0 to 7.4.0 [beam] via GitHub
• [PR] AddFiles: Add dry_run [beam] via GitHub
  • Re: [PR] AddFiles: Add dry_run [beam] via GitHub
  • Re: [PR] AddFiles: Add dry_run [beam] via GitHub
  • Re: [PR] AddFiles: Add dry_run [beam] via GitHub
• [PR] [Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers [beam] via GitHub
  • Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers [beam] via GitHub
  • Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers [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
• [PR] Fix JaCoCo coverage for multiple test tasks. [beam] via GitHub
  • Re: [PR] Fix JaCoCo coverage for multiple test tasks. [beam] via GitHub
  • Re: [PR] Fix JaCoCo coverage for multiple test tasks. [beam] via GitHub
• [PR] AddFiles: per-file coverage check and pinned-column enforcement in Co… [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in Co… [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in Co… [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in Co… [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in Co… [beam] via GitHub
• Re: [I] KafkaUnboundedReader doesn't support updating pipeline with re-partition case. [beam] via GitHub
  • Re: [I] KafkaUnboundedReader doesn't support updating pipeline with re-partition case. [beam] via GitHub
• [PR] [Go SDK] Convert logical type arguments to and from schema protos [beam] via GitHub
  • Re: [PR] [Go SDK] Convert logical type arguments to and from schema protos [beam] via GitHub
  • Re: [PR] [Go SDK] Convert logical type arguments to and from schema protos [beam] via GitHub
• [PR] Addfiles wiring provider [beam] via GitHub
  • Re: [PR] Addfiles wiring provider [beam] via GitHub
  • Re: [PR] Addfiles wiring provider [beam] via GitHub
  • Re: [PR] Addfiles wiring provider [beam] via GitHub
  • Re: [PR] Addfiles wiring provider [beam] via GitHub
  • Re: [PR] Addfiles wiring provider [beam] via GitHub
• [PR] Bump vllm from 0.10.1.1 to 0.28.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump vllm from 0.10.1.1 to 0.28.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump vllm from 0.10.1.1 to 0.28.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump vllm from 0.10.1.1 to 0.28.0 in /sdks/python/container/ml/py310 [beam] via GitHub
• Re: [I] Spark portable runner: support SDF [beam] via GitHub
• [I] [Bug]: Go SDK row coder encodes INT16 schema fields as varint instead of big endian [beam] via GitHub
• [PR] [Go SDK] Add the standard timestamp logical type with millisecond, microsecond and nanosecond precision [beam] via GitHub
  • Re: [PR] [Go SDK] Add the standard timestamp logical type with millisecond, microsecond and nanosecond precision [beam] via GitHub
  • Re: [PR] [Go SDK] Add the standard timestamp logical type with millisecond, microsecond and nanosecond precision [beam] via GitHub
• [PR] [Go SDK] Document the standard logical types and the registration API [beam] via GitHub
  • Re: [PR] [Go SDK] Document the standard logical types and the registration API [beam] via GitHub
  • Re: [PR] [Go SDK] Document the standard logical types and the registration API [beam] via GitHub
• Re: [PR] If the partition count or kafka IO size is large, then skip committin… [beam] via GitHub
• [PR] [Iceberg CDC sink] Top API layer [beam] via GitHub
• [I] [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject [beam] via GitHub
  • Re: [I] [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject [beam] via GitHub
  • [I] [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject [beam] via GitHub
  • Re: [I] [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject [beam] via GitHub
• [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] via GitHub
  • Re: [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] via GitHub
  • Re: [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] via GitHub
  • Re: [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] via GitHub
  • Re: [PR] [Go SDK] Encode INT16 row fields as big endian to match Java and Python [beam] via GitHub
• [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] via GitHub
  • Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] via GitHub
  • Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] via GitHub
• [PR] [Go SDK] Add portable logical type registration and standard date and micros_instant types [beam] via GitHub
  • Re: [PR] [Go SDK] Add portable logical type registration and standard date and micros_instant types [beam] via GitHub
• [PR] [Go SDK] Add the standard millis_instant and decimal logical types [beam] via GitHub
  • Re: [PR] [Go SDK] Add the standard millis_instant and decimal logical types [beam] via GitHub
  • Re: [PR] [Go SDK] Add the standard millis_instant and decimal logical types [beam] via GitHub
• Re: [I] [Bug]: Python Enrichment BigQuery handler does not expose `max_batch_duration_secs` to `BatchElements` [beam] via GitHub
• [PR] Flink dropping watermarks fix [beam] via GitHub
  • Re: [PR] Flink dropping watermarks fix [beam] via GitHub
  • Re: [PR] Flink dropping watermarks hold fix [beam] via GitHub
  • Re: [PR] Flink dropping watermarks hold fix [beam] via GitHub
• Re: [I] Eliminate nullability errors from :sdks:java:extensions:sorter [beam] via GitHub
• [PR] Add -PshowTests to print each test as it runs in gradle [beam] via GitHub
  • Re: [PR] Add -PshowTests to print each test as it runs in gradle [beam] via GitHub
  • Re: [PR] Add -PshowTests to print each test as it runs in gradle [beam] via GitHub
  • Re: [PR] Add -PshowTests to print each test as it runs in gradle [beam] via GitHub
  • Re: [PR] Add -PshowTests to print each test as it runs in gradle [beam] via GitHub
  • Re: [PR] Add -PshowTests to print each test as it runs in gradle [beam] via GitHub
• [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
  • Re: [PR] Remove blanket nullness suppressions in google-cloud-platform-core [beam] via GitHub
• Re: [I] Eliminate nullability errors from :sdks:java:extensions:google-cloud-platform-core [beam] via GitHub
• [PR] Update Dataflow container versions to 20260916 [beam] via GitHub
  • Re: [PR] Update Dataflow container versions to 20260916 [beam] via GitHub
  • Re: [PR] Update Dataflow container versions to 20260916 [beam] via GitHub
  • Re: [PR] Update Dataflow container versions to 20260916 [beam] via GitHub
• [I] [Feature Request]: Add schema evolution/deduction to AddFiles [beam] via GitHub
• [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] via GitHub
  • Re: [PR] AddFiles: per-file coverage check and pinned-column enforcement in ConvertToDataFile [beam] via GitHub
• [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
  • Re: [PR] Add GCS performance metrics and new load tests [beam] via GitHub
• Re: [I] Can't use side inputs with Combine.PerKeyWithHotKeyFanout [beam] via GitHub
• [PR] [CI] Fix label race condition between LabelPrs and pr-bot-pr-updates [beam] via GitHub
  • Re: [PR] [CI] Fix label race condition between LabelPrs and pr-bot-pr-updates [beam] via GitHub
  • Re: [PR] [CI] Fix label race condition between LabelPrs and pr-bot-pr-updates [beam] via GitHub
  • Re: [PR] [CI] Fix label race condition between LabelPrs and pr-bot-pr-updates [beam] via GitHub
  • Re: [PR] [CI] Fix label race condition between LabelPrs and pr-bot-pr-updates [beam] via GitHub
• [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
  • Re: [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
  • Re: [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
  • Re: [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
  • Re: [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
  • Re: [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
  • Re: [PR] Expose Public API for Iceberg Side Input Cache [beam] via GitHub
• [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
  • Re: [PR] Re-enable the TensorRT integration test [beam] via GitHub
• Re: [I] Code coverage numbers are not accurate [beam] via GitHub
  • Re: [I] Code coverage numbers are not accurate [beam] via GitHub
• Re: [I] Impossible to submit Google Dataflow job from Windows machine [beam] via GitHub
  • Re: [I] Impossible to submit Google Dataflow job from Windows machine [beam] via GitHub
  • Re: [I] Impossible to submit Google Dataflow job from Windows machine [beam] via GitHub
  • Re: [I] Impossible to submit Google Dataflow job from Windows machine [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.111.0 to 1.113.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.111.0 to 1.113.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.111.0 to 1.113.1 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.4 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.4 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.4 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.4 in /sdks [beam] via GitHub

• Earlier messages