github  

Messages by Date

• 2026/11/08 Re: [I] [Bug]: HuggingFaceModelHandlerTensor passes inference_args instead of device to a custom inference_fn [beam] sohailshk (via GitHub) via github
• 2026/11/08 Re: [PR] Handle partial Dataflow metric updates [beam] github-actions[bot] (via GitHub) via github
• 2026/11/08 [PR] Handle partial Dataflow metric updates [beam] 09Catho (via GitHub) via github
• 2026/11/08 Re: [PR] Always resolve builtin types in dataclass field type inference [beam] github-actions[bot] (via GitHub) via github
• 2026/11/08 Re: [I] [Bug]: [Python/Dataflow] DataflowMetrics._populate_metrics raises KeyError when only tentative or committed metric is present [beam] 09Catho (via GitHub) via github
• 2026/11/08 Re: [PR] [BEAM-41079] Fix StringCompiler classpath resolution[BEAM-41079] Fix StringCompiler classpath resolution [beam] Tarun4201 (via GitHub) via github
• 2026/11/08 [PR] [BEAM-41079] Fix StringCompiler classpath resolution[BEAM-41079] Fix StringCompiler classpath resolution [beam] Tarun4201 (via GitHub) via github
• 2026/11/07 [I] [Feature Request]: [YAML] Support error_handling dead-letter output on ReadFromCsv and ReadFromJson [beam] jk-shah (via GitHub) via github
• 2026/11/07 [I] [Bug]: [Spark/Python] --spark_submit_uber_jar fails in StorageLevelFactory.create due to Python runner name lookup [beam] jk-shah (via GitHub) via github
• 2026/11/07 [I] [Bug]: [Java/YAML] StringCompiler fails to resolve org.apache.beam.sdk.values.Row inside Java SDK harness container [beam] jk-shah (via GitHub) via github
• 2026/11/07 [I] [Bug]: [Python/YAML] MapToFields / Filter expression raises SyntaxError when schema contains Python keyword column names [beam] jk-shah (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Buffer all committed metric payloads before short ID resolution [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Go] Add optional random access to the filesystem API [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] [Prism] Buffer all committed metric payloads before short ID resolution [beam] prodriguezdefino (via GitHub) via github
• 2026/11/07 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Advance aggregation stage watermark past emitted accumulating… [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Omit cleared keys from MultimapKeysUserState [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Advance aggregation stage watermark past emitted accumulating… [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] [Prism] Omit cleared keys from MultimapKeysUserState [beam] prodriguezdefino (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Honor clear requests for processing-time timers [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Honor clear requests for processing-time timers [beam] prodriguezdefino (via GitHub) via github
• 2026/11/07 [PR] [Prism] Honor clear requests for processing-time timers [beam] prodriguezdefino (via GitHub) via github
• 2026/11/07 [PR] [Prism] Advance aggregation stage watermark past emitted accumulating… [beam] prodriguezdefino (via GitHub) via github
• 2026/11/07 Re: [PR] [Dataflow Streaming] [MultiKey] Handle work cancellation exceptions in WorkFailureProcessor. [beam] arunpandianp (via GitHub) via github
• 2026/11/07 Re: [PR] [Go] Add optional random access to the filesystem API [beam] goutamadwant (via GitHub) via github
• 2026/11/07 [PR] Update cython requirement from <4,>=3.2.6 to >=3.3.1,<4 in /sdks/python [beam] dependabot[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Website] Fix the code examples on the Test Your Pipeline page [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [I] [Feature Request]: Support Beam Python on macos arm64. [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [I] [Task][Maintenance]: Maintain Apache Beam Quest Labs [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: Possible data loss in BigtableIO r/w if timestamp not set (default to epoch) [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [SpannerIO] Add UUID and ARRAY<UUID> support for mutations, structs and change streams [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Bind Prism JobManagement server to localhost by default [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] [Python] Fix WriteToFiles crashing when the sink writes compressed files [beam] PDGGK (via GitHub) via github
• 2026/11/07 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] jbonofre (via GitHub) via github
• 2026/11/07 Re: [PR] [JmsIO] Acknowledge messages of checkpoints that are never finalized [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Java][BigQueryIO] Avoid reflective lookup in unknown-column collectors [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] [#36841] Spark 4 streaming: ValidatesRunner suite for the Structured Streaming runner [beam] tkaymak (via GitHub) via github
• 2026/11/07 Re: [I] [Feature Request]: Support running multi-language pipelines locally without Docker [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Fix broken GlobalWindow singleton [beam] Abacn (via GitHub) via github
• 2026/11/07 Re: [PR] Update beam-site PR on release candidate reruns [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] make tests order independent [beam] codecov[bot] (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: Beam Website cannot run locally on Mac [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Stable code identifier pickling [beam] kristynsmith (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: Run shortcut losed in shortcuts modal window [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Stable code identifier pickling [beam] kristynsmith (via GitHub) via github
• 2026/11/07 Re: [PR] Add WITH clause to Beam SQL to set connector properties [beam] chamikaramj (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: Possible data loss in BigtableIO r/w if timestamp not set (default to epoch) [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Support java_gc experiment in Java SDK harness container [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Move BundleLifter from Iceberg to sdk/util [beam] scwhittle (via GitHub) via github
• 2026/11/07 Re: [PR] [RunInference] Raise when a model handler returns fewer predictions than inputs [beam] jrmccluskey (via GitHub) via github
• 2026/11/07 Re: [PR] [Beam SQL] Fix column swaps and table show [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] jbonofre (via GitHub) via github
• 2026/11/07 Re: [PR] Wait for SingleStore LoadBalancer TCP port 3306 readiness in SingleStoreIO IT [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] Implement LLM-driven review assigner for PR bot [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Prism] Fix GroupIntoBatches losing or misframing batches [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] fix: run all HBaseIO cleanup steps even if an earlier close() throws [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] fix: run all HBaseIO cleanup steps even if an earlier close() throws [fj4WqyCCw3C5ShR1RfB7MoBPTpkRrBFYP1uT35g3MvT] [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Port ReadSpannerSchemaTest off deprecated DoFnTester [beam] Supersaiyan101 (via GitHub) via github
• 2026/11/07 Re: [PR] [yaml] - update enrichment testing [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] Synchronize namespace creation in RecordWriterManager and apply targetParallelism=1 in IcebergCatalogBaseIT [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] Update Python Dependencies [beam] tvalentyn (via GitHub) via github
• 2026/11/07 Re: [PR] Harden RabbitMQ deployment and readiness wait for SparkReceiverIOIT [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [I] how to import source code to my ide(idea)? [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] add snakeyaml dep to managed module [beam] ahmedabu98 (via GitHub) via github
• 2026/11/07 Re: [PR] Fix flaky PipelineBasedStreamingInsertTest.test_failure_in_some_rows_does_not_duplicate [beam] codecov[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 7.2.1 to 8.11.0 [beam] derrickaw (via GitHub) via github
• 2026/11/07 Re: [PR] [#18690] Port Iceberg IO tests off deprecated DoFnTester [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Log systemname 2 cache [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [YAML] Fix SQL-backed Join generating invalid syntax when joining 3+ inputs [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 [PR] Retry cibuildwheel in build_wheels.yml to handle container teardown timeouts [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] Backport #40996 into 2.77.0-postrelease branch [beam] Abacn (via GitHub) via github
• 2026/11/07 Re: [I] [Feature Request]: Creation of BigQuery clone table via BigQueryIO [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Python] Add beam pipe to the experimental beam command (#40891) [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Website] Fix the Parquet type mapping table for Beam SQL CREATE EXTERNAL TABLE [beam] jonathansudhakar1 (via GitHub) via github
• 2026/11/07 Re: [I] The Publish Website job is flaky [beam] Abacn (via GitHub) via github
• 2026/11/07 Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] lostluck (via GitHub) via github
• 2026/11/07 Re: [PR] [Python] Optimize RunInference PyTorch/HF get_num_bytes and Sklearn Pandas batching [beam] codecov[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] lostluck (via GitHub) via github
• 2026/11/07 Re: [PR] [Python/YAML] Accept >=, <=, == and != in generic Filter expressions … [beam] derrickaw (via GitHub) via github
• 2026/11/07 [PR] Include streaming and numberOfWorkerHarnessThreads in Go Dataflow sdk_pipeline_options.options [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: SDK container `boot` binary built with go1.26.2 — 13 Go stdlib CVEs (HIGH) fixed in go1.26.10, still present in 2.78.0 [beam] schizophrenicmaniac (via GitHub) via github
• 2026/11/07 Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] lostluck (via GitHub) via github
• 2026/11/07 Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] Eliaaazzz (via GitHub) via github
• 2026/11/07 Re: [PR] [#18690] Port Iceberg IO tests off deprecated DoFnTester [beam] Supersaiyan101 (via GitHub) via github
• 2026/11/07 Re: [PR] use Python 3.12 for TensorRT benchmarks [beam] Abacn (via GitHub) via github
• 2026/11/07 Re: [I] Document Python custom metrics in programming guide [beam] jonathansudhakar1 (via GitHub) via github
• 2026/11/07 Re: [PR] [Java] Improve ProtoCoder decode error for raw Message type [beam] jonathansudhakar1 (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: ParDo#with_exception_handling(use_subprocess=True) doesn't work because of missing _context.process_instruction_id [beam] jonathansudhakar1 (via GitHub) via github
• 2026/11/07 Re: [PR] Wait for Flink mini cluster REST server before submitting uber jar [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] [Spark] Fix zero buffer size in ValueAndCoderLazySerializable for cheap coders [beam] vishalmore90 (via GitHub) via github
• 2026/11/07 Re: [I] [Bug]: BundleProcessorCache calls shutdown on timed out DoFns inline, blocking unrelated processing [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] fix: preserve duplicate same-timestamp elements in FlinkOrderedListState [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [I] [Task]: Refactor Jenkins PostcommitJobBuilder to behave similarly as PrecommitJobBuilder [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [I] [Task][Maintenance]: Maintain Apache Beam Quest Labs [beam] github-actions[bot] (via GitHub) via github
• 2026/11/07 Re: [PR] Wait for SingleStore LoadBalancer TCP port 3306 readiness in SingleStoreIO IT [beam] damccorm (via GitHub) via github
• 2026/11/07 [PR] Wait for SingleStore LoadBalancer TCP port 3306 readiness in SingleStoreIO IT [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] use Python 3.12 for TensorRT benchmarks [beam] aIbrahiim (via GitHub) via github
• 2026/11/07 Re: [PR] Retry cibuildwheel in build_wheels.yml to handle container teardown timeouts [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] [Python] Skip attributes that raise during stable code identifier lambda search [beam] thelastbackspace (via GitHub) via github
• 2026/11/07 [PR] [Python] Optimize AvroRowWriter.tell, BigQueryWrapper.insert_rows, and _split_table_spec [beam] damccorm (via GitHub) via github
• 2026/11/07 Re: [PR] Backport #40996 into 2.77.0-postrelease branch [beam] Abacn (via GitHub) via github
• 2026/11/06 Re: [PR] Retry YAML integration test fixture setup on transient Docker/service timeouts [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Support Environment Sensitive Staging [beam] tarun-google (via GitHub) via github
• 2026/11/06 Re: [PR] Retry YAML integration test fixture setup on transient Docker/service timeouts [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer [beam] prodriguezdefino (via GitHub) via github
• 2026/11/06 [PR] Retry YAML integration test fixture setup on transient Docker/service timeouts [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [#34613] Fix SqlTransformSchemaTransformProvider config schema for cross-language use [beam] Brijesh-Thakkar (via GitHub) via github
• 2026/11/06 Re: [PR] Synchronize namespace creation in RecordWriterManager and apply targetParallelism=1 in IcebergCatalogBaseIT [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Run StorageApiSinkRowUpdateIT with targetParallelism=1 to avoid concurrent StreamWriter closure on table creation [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Harden RabbitMQ deployment and readiness wait for SparkReceiverIOIT [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Wait for Flink mini cluster REST server before submitting uber jar [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 [PR] [YAML] Fix SQL-backed Join generating invalid syntax when joining 3+ inputs [beam] vishalmore90 (via GitHub) via github
• 2026/11/06 Re: [PR] Retry Pub/Sub topic and subscription creation in TestPubsub and TestPubsubSignal [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Go SDK] Add pass through registration for the fixed and variable length string and bytes logical types [beam] Eliaaazzz (via GitHub) via github
• 2026/11/06 [PR] Use unique store name in DicomIOReadIT to prevent 409 Conflict across concurrent runs [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Use unique store name in DicomIOReadIT to prevent 409 Conflict across concurrent runs [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] Run StorageApiSinkRowUpdateIT with targetParallelism=1 to avoid concurrent StreamWriter closure on table creation [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] Retry Pub/Sub topic and subscription creation in TestPubsub and TestPubsubSignal [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Run StorageApiSinkRowUpdateIT with targetParallelism=1 to avoid concurrent StreamWriter closure on table creation [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Flink] Copy length-prefixed batch records and decode grouping inputs lazily [beam] jto (via GitHub) via github
• 2026/11/06 [PR] Harden Spark and Flink state execution tests against PreCommit Java load [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Run StorageApiSinkRowUpdateIT with targetParallelism=1 to avoid concurrent StreamWriter closure on table creation [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Run StorageApiSinkRowUpdateIT with targetParallelism=1 to avoid concurrent StreamWriter closure on table creation [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] [Python][RunInference] Deduplicate ModelHandler wrappers via _DelegatingModelHandler [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Add beam pipe to the experimental beam command (#40891) [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [I] [Bug]: Spark runner `ValueAndCoderLazySerializable` sets `bufferSize = 0` for all cheap coders due to omitted `ElementByteSizeObserver.advance()` [beam] vishalmore90 (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize AvroRowWriter.tell, BigQueryWrapper.insert_rows, and _split_table_spec [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Backport #40996 into 2.77.0-postrelease branch [beam] Abacn (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Dataflow Streaming] [MultiKey] Handle work cancellation exceptions in WorkFailureProcessor. [beam] arunpandianp (via GitHub) via github
• 2026/11/06 Re: [PR] [Dataflow Streaming] [MultiKey] Handle work cancellation exceptions in WorkFailureProcessor. [beam] arunpandianp (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Retry cibuildwheel in build_wheels.yml to handle container teardown timeouts [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [codecov] - add token to precommit python coverage workflow [beam] derrickaw (via GitHub) via github
• 2026/11/06 Re: [PR] Increase Gradle wrapper networkTimeout and retry wrapper bootstrap on cache miss [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] Increase Gradle wrapper networkTimeout and retry wrapper bootstrap on cache miss [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Harden RabbitMQ deployment and readiness wait for SparkReceiverIOIT [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Harden Spark and Flink state execution tests against PreCommit Java load [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [I] [Failing Test]: Pylint failed when hypothesis > 6.148.3 is used [beam] shunping (via GitHub) via github
• 2026/11/06 Re: [PR] Retry Pub/Sub topic and subscription creation in TestPubsub and TestPubsubSignal [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Clean up remaining Python 3.10 references [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Harden Spark and Flink state execution tests against PreCommit Java load [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [SolaceIO] Keep shared Solace write sessions open across DoFn teardown [beam] stankiewicz (via GitHub) via github
• 2026/11/06 Re: [PR] Clean up remaining Python 3.10 references [beam] jrmccluskey (via GitHub) via github
• 2026/11/06 Re: [I] [Bug]: [YAML] WindowInto parses 'd' (days) as 12 hours instead of 24 hours, and ExtractWindowingInfo fails to detect duplicate schema fields [beam] derrickaw (via GitHub) via github
• 2026/11/06 [PR] Harden RabbitMQ deployment and readiness wait for SparkReceiverIOIT [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Harden RabbitMQ deployment and readiness wait for SparkReceiverIOIT [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [I] Use ruptures module for detecting change points in performance tests. [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 7.2.1 to 8.11.0 [beam] dependabot[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [JmsIO] Let restored checkpoint marks acknowledge live messages [beam] jbonofre (via GitHub) via github
• 2026/11/06 Re: [PR] Add WITH clause to Beam SQL to set connector properties [beam] ahmedabu98 (via GitHub) via github
• 2026/11/06 Re: [PR] [yaml] - update enrichment testing [beam] derrickaw (via GitHub) via github
• 2026/11/06 [PR] Add Credit Karma ML model explainability case study [beam] 04pallav (via GitHub) via github
• 2026/11/06 Re: [PR] [Java] BigQueryIO: set table labels from dynamic destinations [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Upgrade Iceberg dependency to 1.12.0 [beam] ahmedabu98 (via GitHub) via github
• 2026/11/06 Re: [I] [Bug]: Beam SQL docs: the Parquet type mapping table on the CREATE EXTERNAL TABLE page is wrong [beam] jonathansudhakar1 (via GitHub) via github
• 2026/11/06 Re: [PR] [Cherrypick] Clean up remaining Python 3.10 references (#40972) [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize AvroRowWriter.tell, BigQueryWrapper.insert_rows, and _split_table_spec [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Attach RunInference model_identifier only to the inference ParDo with exception handling [beam] Brijesh-Thakkar (via GitHub) via github
• 2026/11/06 Re: [PR] [Prism] Fix flaky TestPersistBundle_ResidualResumeDelay bound [beam] jrmccluskey (via GitHub) via github
• 2026/11/06 Re: [I] [Feature Request]: WriteToParquet schema as side input [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Wait for expansion services to listen before running XVR tests [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Flink] Re-split and balance bounded source splits in batch [beam] jto (via GitHub) via github
• 2026/11/06 Re: [I] [Task]: disable examples checks in integration tests [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Add an experimental beam command with beam run #40891 [beam] jk-shah (via GitHub) via github
• 2026/11/06 Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 7.2.1 to 8.11.0 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python/YAML] Accept >=, <=, == and != in generic Filter expressions … [beam] derrickaw (via GitHub) via github
• 2026/11/06 Re: [PR] [Website] Fix the Parquet type mapping table for Beam SQL CREATE EXTERNAL TABLE [beam] jonathansudhakar1 (via GitHub) via github
• 2026/11/06 Re: [PR] [release-2.78.0] Update pillow version to remediate some known vulnerabitlites and reduce the vuln checker alerts. [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python][RunInference] Deduplicate ModelHandler wrappers via _DelegatingModelHandler [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 [PR] Use side inputs to implement non-compressing to singleton global combines. [beam] robertwb (via GitHub) via github
• 2026/11/06 Re: [PR] Exp [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Update collaborators in .asf.yaml [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Java] Support cross-chunk element decoding in UncachedStateIterable [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [I] [Improvement]: accept collections.abc.Iterable[T] as a type hint [beam] tvalentyn (via GitHub) via github
• 2026/11/06 Re: [PR] Use side inputs to implement non-compressing to singleton global combines. [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Cache opcode dispatch tables in trivial_inference and atomic types in SchemaTranslation [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [I] [Bug]: [Python/YAML] Beam YAML generic Filter rejects >=, <=, ==, and != comparisons [beam] derrickaw (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize RunInference PyTorch/HF get_num_bytes and Sklearn Pandas batching [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Cache opcode dispatch tables in trivial_inference and atomic types in SchemaTranslation [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Optimize AvroRowWriter.tell, BigQueryWrapper.insert_rows, and _split_table_spec [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] [Python] Optimize RunInference PyTorch/HF get_num_bytes and Sklearn Pandas batching [beam] damccorm (via GitHub) via github
• 2026/11/06 [PR] [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] [Python/YAML] Accept >=, <=, == and != in generic Filter expressions … [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Fix rebatching into multi-column pyarrow Tables (#41042) [beam] codecov[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Update managed-io.md for release 2.78.0-RC2 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Use side inputs to implement non-compressing to singleton global combines. [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [PR] Backport #40996 into 2.77.0-postrelease branch [beam] github-actions[bot] (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Add an experimental beam command with beam run #40891 [beam] jk-shah (via GitHub) via github
• 2026/11/06 Re: [PR] [Python] Fix rebatching into multi-column pyarrow Tables (#41042) [beam] damccorm (via GitHub) via github
• 2026/11/06 Re: [I] [Bug]: [Python] Batched DoFn rebatched into a multi-column pyarrow.Table fails with ArrowInvalid (breaks YAML ReadFromCsv -> WriteToParquet) [beam] damccorm (via GitHub) via github

• Earlier messages
• Later messages