Messages by Thread
-
-
[PR] Fix TSAN bug by swapping ForkJoinPool with ScheduledExecutorService [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.31 to 1.19.32 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.106.1 to 1.106.2 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.36 to 1.22.37 in /sdks [beam]
via GitHub
-
[PR] Bump docker/login-action from 4.5.2 to 4.6.0 [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.32 to 1.32.33 in /sdks [beam]
via GitHub
-
[PR] Bump cloud.google.com/go/spanner from 1.93.0 to 1.94.0 in /sdks [beam]
via GitHub
-
Re: [PR] Buffer BufferedLogger by newline to avoid log splitting [beam]
via GitHub
-
Re: [PR] [Iceberg CDC] Add Changelog readers and update resolver [beam]
via GitHub
-
[PR] Add Delta Lake to Iceberg Yaml blueprint IT [beam]
via GitHub
-
Re: [I] Revisit timestamp and duration representation [beam]
via GitHub
-
[I] [Bug]: Performance regression and stuck jobs due to gcs-connector v3 upgrade [beam]
via GitHub
-
[PR] [Python] Convert typing and native generic hints in Watch coder inference [beam]
via GitHub
-
Re: [I] [Feature Request]: Allow users to modify _BeamArgumentParser behavior [beam]
via GitHub
-
Re: [I] [Bug]: Type inference failure with closure creation. [beam]
via GitHub
-
Re: [I] [Bug]: Flink fails with "cannot handle nodes with more than 64 outputs" [beam]
via GitHub
-
Re: [I] [Feature Request]: Reduce expense of calculating quantiles [beam]
via GitHub
-
Re: [PR] Add Dynamic Schema support to StorageWriteToBigQuery [beam]
via GitHub
-
Re: [PR] [Dataflow Streaming] [Multi Key] Drop failed work in BoundedQueueExecutor::pollWork [beam]
via GitHub
-
Re: [PR] Add query_output_schema to ReadFromBigQuery for BEAM_ROW + query support [beam]
via GitHub
-
Re: [PR] Potential fix for environment variable built from user-controlled sources [beam]
via GitHub
-
Re: [PR] Support core dump analysis with pystack. [beam]
via GitHub
-
[PR] [GSoC 2026] Kafka Streams runner: run against a real broker [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run against a real broker [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run against a real broker [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
Re: [PR] [GSoC 2026] Kafka Streams runner: run on a real broker, correctly across partitions [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.35 to 1.22.36 in /sdks [beam]
via GitHub
-
[PR] Bump google.golang.org/api from 0.290.0 to 0.291.0 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/credentials from 1.19.30 to 1.19.31 in /sdks [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.0 to 1.43.1 in /sdks [beam]
via GitHub
-
[PR] Bump docker/login-action from 4.5.1 to 4.5.2 [beam]
via GitHub
-
[PR] Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.106.0 to 1.106.1 in /sdks [beam]
via GitHub
-
[PR] Fix flaky BigQuery persistent retry test [beam]
via GitHub
-
[PR] Feat: A new prefix was added to the cleaner to clean up newly discove⦠[beam]
via GitHub
-
[PR] Enhance Python Timestamp to be precision-variable up to nanos, and map it to Timestamp logical type [beam]
via GitHub
-
[I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam]
via GitHub
-
Re: [PR] Support IBM MQ for Python JmsIO [beam]
via GitHub
-
[PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam]
via GitHub
-
Re: [PR] KeyCommitTooLarge logging improvements [beam]
via GitHub
-
[PR] Fix Update Python Dependencies [beam]
via GitHub
-
Re: [I] Add an Arrow Flight based Java IO connector [beam]
via GitHub
-
Re: [PR] [Python] Refactor MatchContinuously onto the Watch transform [beam]
via GitHub