Messages by Thread
-
-
[I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime [beam]
via GitHub
-
[I] [Feature Request]: Honor `allowMissingRequiredFields` when building Storage Write API messages from TableRow [beam]
via GitHub
-
[I] [Feature Request]: Avoid per-field `Descriptor.findFieldByName` lookups in BigQuery Storage Write API TableRow conversion [beam]
via GitHub
-
Re: [I] [Feature Request]: Write integration tests for DICOM IO (Java SDK) [beam]
via GitHub
-
Re: [PR] Merge runtime type-checking wrappers into a single layer (BEAM-9489) [beam]
via GitHub
-
Re: [I] [Feature Request]: Add ARM unit test suites for all Beam SDK languages [beam]
via GitHub
-
[PR] Add OpenTelemetry tracing support to SolaceIO [beam]
via GitHub
-
[PR] Kafka Streams runner: target flush markers across repartition topics [beam]
via GitHub
-
Re: [I] [Feature Request]: Add Postcommit Dataflow ARM tests for Java and Python [beam]
via GitHub
-
Re: [I] [Feature Request]: Add a basic doc explaining Beam's security model [beam]
via GitHub
-
[I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam]
via GitHub
-
[PR] Several small updates to YAML ML examples [beam]
via GitHub
-
Re: [PR] Expand Beam Python heap dump with process/native memory stats (#39244) [beam]
via GitHub
-
[PR] [Python] Make read and write buffer size configurable in gcsio [beam]
via GitHub
-
[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
-
[PR] Remove upper bound pin for cryptography. [beam]
via GitHub
-
[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
-
[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
-
Re: [I] [Bug][prism]: Stand alone binary should fail if unable to bind port + allow specifying Job Management + UI ports. [beam]
via GitHub
-
Re: [I] [Task]: Handle time.Time and time.Duration in Go xlang [beam]
via GitHub
-
[PR] normalize BigQuery CDC [beam]
via GitHub
-
[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
-
[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
-
[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
-
[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
-
[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
-
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
-
Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers [beam]
via GitHub
-
Re: [PR] [Go SDK] PostgreSQLIO core configuration, write sinks [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: [I] [Feature Request]: Allow disable user metrics in Python SDK [beam]
via GitHub
-
[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: [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
-
[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: [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
-
[PR] [Go SDK] Document the standard logical types and the registration API [beam]
via GitHub