Messages by Thread
-
-
[I] [Bug]: MLTransform and RAG embedding output functions modify their input elements [beam]
sohailshk (via GitHub) via github
-
[I] [Bug]: MajorityVote tie_breaker ignores a custom normal_label [beam]
sohailshk (via GitHub) via github
-
[PR] Pass explicit timestamps for DirectRow.commit setup writes in Bigtable ITs [beam]
damccorm (via GitHub) via github
-
[PR] Bump pillow from 12.3.0 to 13.0.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train [beam]
dependabot[bot] (via GitHub) via github
-
[PR] Require processing time advancement before firing TriggerAfterSynchronizedProcessingTime in Prism [beam]
damccorm (via GitHub) via github
-
[PR] Pin pyarrow<26 in run_perf_alert_tool.yml for NumPy 1 compatibility [beam]
damccorm (via GitHub) via github
-
[I] [Feature Request]: [Iceberg/Managed] Continuous streaming snapshot commit watermarking in beam.managed.Write(ICEBERG) [beam]
jk-shah (via GitHub) via github
-
[I] [Feature Request]: [Lakehouse/Python] Partition-aware zero-copy metadata translation from Delta Lake to Apache Iceberg [beam]
jk-shah (via GitHub) via github
-
[I] [Feature Request]: [Kafka/YAML] Turnkey Confluent Schema Registry Wire Format deserializer in ReadFromKafka [beam]
jk-shah (via GitHub) via github
-
[I] [Feature Request]: [Streaming/YAML] Add declarative IntervalJoin composite transform with watermark skew circuit breaker [beam]
jk-shah (via GitHub) via github
-
[I] [Feature Request]: [Python/YAML] Add native Expect / data quality PTransform with tagged DLQ outputs [beam]
jk-shah (via GitHub) via github
-
[PR] Allow disk use in MongoDbIO aggregations to avoid sort memory limit [beam]
mxtymoshyk (via GitHub) via github
-
Re: [I] [Feature Request]: Utils to translate RunnerApi.Pipeline to the normal beam Pipeline object [beam]
mxtymoshyk (via GitHub) via github
-
[PR] Bump beartype upper bound [beam]
aebrahim (via GitHub) via github
-
Re: [I] [Bug]: retain_unknown_options incorrectly assumes unknown arguments are consecutive [beam]
jrmccluskey (via GitHub) via github
-
[PR] [#40949] Spark 4 streaming: stateless ParDo with additional outputs [beam]
tkaymak (via GitHub) via github
-
[PR] Increase expansion service startup wait timeout to 180s in run_expansion_services.sh [beam]
damccorm (via GitHub) via github
-
Re: [I] [Failing Test]: Re-enable the skipped Change Stream Unit tests after refactor test code [beam]
jonathansudhakar1 (via GitHub) via github
-
Re: [I] Port BigQueryIOWriteTest off DoFnTester [beam]
ahmedabu98 (via GitHub) via github
-
[PR] Republish released docker containers daily [beam]
Abacn (via GitHub) via github
-
[PR] [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation [beam]
github-actions[bot] (via GitHub) via github
-
Re: [PR] [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation [beam]
codecov[bot] (via GitHub) via github
-
[PR] [Python] Unroll 2-component KV fast path in AbstractComponentCoderImpl [beam]
damccorm (via GitHub) via github
-
[PR] Port ElasticsearchIOTest off DoFnTester [beam]
harshilv17 (via GitHub) via github
-
Re: [I] Port ElasticSearchIOTest off DoFnTester [beam]
harshilv17 (via GitHub) via github
-
Re: [PR] [Java] Fix BigQuery failed-row timestamp conversion [beam]
goutamadwant (via GitHub) via github
-
[PR] [Python] Optimize FastPrimitivesCoderImpl.encode_to_stream for lists, tuples, dicts, and ints [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize FastPrimitivesCoderImpl.encode_to_stream for lists, tuples, dicts, and ints [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize FastPrimitivesCoderImpl.encode_to_stream for lists, tuples, dicts, and ints [beam]
codecov[bot] (via GitHub) via github
-
Re: [PR] [Python] Optimize FastPrimitivesCoderImpl.encode_to_stream for lists, tuples, dicts, and ints [beam]
damccorm (via GitHub) via github
-
Re: [PR] [Python] Optimize FastPrimitivesCoderImpl.encode_to_stream for lists, tuples, dicts, and ints [beam]
damccorm (via GitHub) via github
-
[PR] [Python] Add Cython StrUtf8CoderImpl and optimize BytesCoderImpl [beam]
damccorm (via GitHub) via github
-
[I] [Feature Request]: Support BigQuery reservation for Java BigQueryIO FILE_LOADS [beam]
paragpratim (via GitHub) via github
-
[PR] Upgrade Tour of Beam Backend Dependencies [beam]
jrmccluskey (via GitHub) via github
-
[PR] Upgrade Beam Playground Dependencies [beam]
jrmccluskey (via GitHub) via github
-
[PR] [Python] Inline and remove _OutputHandler._handle_tagged_output [beam]
damccorm (via GitHub) via github
-
[PR] Prevent background computation leak in test_async_computation_result_cancel [beam]
damccorm (via GitHub) via github
-
[PR] Add `summarize-failures` action to use on PRs [beam]
derrickaw (via GitHub) via github
-
Re: [I] [Feature Request]: Support custom AWS credentials providers [beam]
github-actions[bot] (via GitHub) via github
-
[PR] Increase Postgres LoadBalancer IP wait timeout in JDBC and HadoopFormat PerformanceTests [beam]
damccorm (via GitHub) via github
-
[PR] Pass reshuffle=False to beam.Create in TestBigQueryFileLoads waiting job tests [beam]
damccorm (via GitHub) via github
-
[PR] Sleep between create_stream retry attempts when waiting for LocalStack in Kinesis ITs [beam]
damccorm (via GitHub) via github
-
Re: [I] WindowFnTestUtils#runWindowFn should be removed [beam]
harshilv17 (via GitHub) via github
-
[PR] [Docker] Install Go toolchain matching the image architecture [beam]
ayush-builds-stuff (via GitHub) via github
-
[PR] Port BatchViewOverridesTest off DoFnTester [beam]
harshilv17 (via GitHub) via github
-
Re: [I] Port BatchViewOverridesTest off DoFnTester [beam]
harshilv17 (via GitHub) via github
-
[PR] [Python] Build nested rows for struct values in pyarrow batch converters [beam]
Thanatos9404 (via GitHub) via github
-
[PR] fix inference python benchmark failures [beam]
aIbrahiim (via GitHub) via github
-
[I] [Bug]: Spark 4 streaming runner runs a shared upstream once per consuming branch [beam]
tkaymak (via GitHub) via github
-
[I] [Bug]: Combine with hot key fanout computes a wrong result on the Spark 4 streaming runner [beam]
tkaymak (via GitHub) via github
-
[I] Release notes links wrong [beam]
ulsa (via GitHub) via github
-
[I] [Bug]: Anthropic request functions remove max_tokens from the shared inference_args [beam]
sohailshk (via GitHub) via github
-
[PR] [RunInference] Do not mutate inference_args in the Anthropic request functions [beam]
sohailshk (via GitHub) via github
-
[I] [Bug]: MonotonicWatermarkEstimator raises TypeError when it starts without a watermark [beam]
sohailshk (via GitHub) via github
-
[PR] [Python] Handle a missing initial watermark in MonotonicWatermarkEstimator [beam]
sohailshk (via GitHub) via github
-
[PR] Bump cloud.google.com/go/pubsub/v2 from 2.8.0 to 2.8.1 in /sdks [beam]
dependabot[bot] (via GitHub) via github
-
[PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.33.15 to 1.33.16 in /sdks [beam]
dependabot[bot] (via GitHub) via github
-
[PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.21 to 1.23.22 in /sdks [beam]
dependabot[bot] (via GitHub) via github
-
[PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.15 to 1.20.16 in /sdks [beam]
dependabot[bot] (via GitHub) via github