github

Messages by Date

2026/11/09 Re: [I] Simple transform to make schema'd PCollections. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Support OrderedListState in Google Cloud Dataflow Runner V2 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] FnApiTimer should expose clear() API [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Unbounded SDF wrapper causes performance regression on DirectRunner [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Remove unnecessary reshuffle for stateful ParDo after keyed operation [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Unbounded SDF wrapper causes performance regression on DirectRunner [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Finalize the input type for the FhirIO.search transform [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Support file checksum throughout filesystems [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Merge redundant metrics from nexmark monitors and remove unused monitor from endOfStreamMonitor [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Support file checksum throughout filesystems [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Add PipelineOptions as DoFn @Setup parameters [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Byte-based GroupByKey in Flink Streaming [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Add the ability to specify resource hints to the Beam environments [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Finalize the input type for the FhirIO.search transform [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Division By Zero errors being thrown by new BQ Source [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Remove PrettyPrinting from json job definition [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Remove PrettyPrinting from json job definition [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Add the ability to specify resource hints to the Beam environments [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Division By Zero errors being thrown by new BQ Source [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] FileIO.Write overwrites destination files on retries [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] FileIO.Write overwrites destination files on retries [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Apache Beam Kafka Source Connector Idle Partition Issue with “CustomTimeStampPolicyWithLimitedDelay” [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] PairWithVoid consolidation yields should have packed name. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Implement new BigQuery sink (Vortex) [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Improve caching experience on InteractiveRunner with dataframes [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Apache Beam Kafka Source Connector Idle Partition Issue with “CustomTimeStampPolicyWithLimitedDelay” [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Some DataFrame operations yield incorrect proxies [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Configure PubsubIO with dead-letter topic [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Enable BigQueryIO to receive a project argument so that jobs will run on that project [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Configure PubsubIO with dead-letter topic [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Allow user to select their own version of Avro when running portably. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] GroupIntoBatches does not properly maintain watermarks [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Java expansion service does not recognize filesToStage argument [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Pubsub-IO dynamic destination [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Direct Runner State is null while active timers exist [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] GroupIntoBatches does not properly maintain watermarks [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] error-prone UnusedVariable check raises false positives for StateId and TimerId usages [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Python portable SDK harness does not import beam_plugins at startup [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Configurable combiner packing limit [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Configurable combiner packing limit [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] BigQueryIO batch writes should output "void" elements when successful [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Add resource location hints to base RunInference Implementation [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Add resource location hints to base RunInference Implementation [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Enable JavaUsingPython CrossLanguageValidateRunner test for dataflow runner v2 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] BigQueryIO failed to load data to temp table when withSchemaUpdateOptions is set. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Idle streams in BiQuery Storage API [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Upgrade bytebuddy 1.12.8 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Java expansion service does not recognize filesToStage argument [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Allow managed thread count in AvroIO [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Update to TextIO to support ValueProviders breaks runner-chosen sharding [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Enable BigQueryIO to receive a project argument so that jobs will run on that project [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Python portable SDK harness does not import beam_plugins at startup [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Pub/Sub Lite support for Python SDK [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] upload to s3 fails if last chunk in finish happens to be of 0 length [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] FhirIO import functionality does unnecessary sharding of import files [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Allow a timer to have no watermark hold [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Portable representation of "packed bitset indicating null fields" in beam Row format is not compatible with jvm representations [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Allow user to select their own version of Avro when running portably. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Go SDK: coder.RegisterCoder needs more precise docstring [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Performance problems when using Storage API writes [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] AsIter side input is not correctly recognized as a dependency. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Update to TextIO to support ValueProviders breaks runner-chosen sharding [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] BigQueryIO failed to load data to temp table when withSchemaUpdateOptions is set. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Website] Add Arrows to Carousel on Home page [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] error-prone UnusedVariable check raises false positives for StateId and TimerId usages [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] FhirIO import functionality does unnecessary sharding of import files [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] BigQueryIO batch writes should output "void" elements when successful [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Performance problems when using Storage API writes [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Upgrade bytebuddy 1.12.8 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] add output_coder_override to ExpansionRequest [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Use runtime information to improve CoGroupByKey caching [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Fix 'RuntimeValueProvider' object has no attribute 'projectId' error in _CustomBigQuerySource.split [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Idle streams in BiQuery Storage API [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Record JFR profiles when GC thrashing is detected [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] WriteToBigQuery with STREAMING_INSERTS needs exception handling tests [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Mapped JOB_STATE_RESOURCE_CLEANING_UP to State.RUNNING [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Pubsub-IO dynamic destination [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] upload to s3 fails if last chunk in finish happens to be of 0 length [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Firestore Beam connector to support readTime [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Implement SingleStoreDB IO Connector [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: ReadFromCSV does not handle EmptyDataframe well internally [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Allow a timer to have no watermark hold [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: RedisIO support pcollection of <byte[], byte[]> in addition to the <String, String> api [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Website] Add Arrows to Carousel on Home page [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Optimize precombining table. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Improve grpc debugging for StreamingDataflowWorker [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Record JFR profiles when GC thrashing is detected [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Add MetadataSpannerConfig class for generating SpannerConfig for accessing change stream metadata database [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Google Colab DataFrame example crashes with dependency conflict [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Mongo DB Upgrade to 5.0 having compatibitlity issue with Apache Beam included mongo-java-driver. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Create separate BigtableIO reader that splits large scans into smaller segments [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: add ci process to tour of beam [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Mongo DB Upgrade to 5.0 having compatibitlity issue with Apache Beam included mongo-java-driver. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Docstring refers to setting "blocking" but there doesn't seem to be a place to set the "blocking" property [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Reject illformed GBK Coders [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Improve grpc debugging for StreamingDataflowWorker [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Optimize precombining table. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] ScopedState can not be re-entered (regression caused by Batched DoFn worker changes) [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Handle failed inserts in Storage API sink [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: upgrade flutter to 3.7.1 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Reject illformed GBK Coders [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Flags with similar name as Pipeline options collide when passed with single dash [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] There is a vulnerability in fastjson-alibaba 1.2.69,upgrade recommended [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Support zstandard decompression on python runner [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Firestore Beam connector to support readTime [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Improve dynamic splitting in BigQuery Read API's Java Connector [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request][Go SDK]: Support Slowly Changing Side Input Pattern [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Add Colab Examples to PTransform Documentation [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] Docstring refers to setting "blocking" but there doesn't seem to be a place to set the "blocking" property [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: In Python how to assign types to multi-output tags? [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Remove CI and CD checks from GitHub workflows [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Duplicate of https://github.com/apache/beam/issues/22896 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: add ci process to tour of beam [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Allow customization of filename and sharding for dataframe IOs. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: ReadFromCSV does not handle EmptyDataframe well internally [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] The PreCommit Java Examples Dataflow Java21 job is flaky [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Tracker]: Clean up spotbug suppressions after upgrading to SpotBugs 4.8 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Google Colab DataFrame example crashes with dependency conflict [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Tracker]: Clean up spotbug suppressions after upgrading to SpotBugs 4.8 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Create a helper function fill_in_missing for TFT Criteo tests [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Flag mismatched Python submission and runtime environments. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Top.Smallest / Largest and the ...PerKey helper combiners should support a comparison key param [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: SchemaTransform Wrapper for SQLTransform [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Feature Request]: Parameterized Query support in Go BigQuery IO connector [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Rename dataflow runner v2 to dataflow portable runner [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Cleanup monkey-patching of numpy once TensorRT supports numpy 1.24.0. [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Task]: Remove CI and CD checks from GitHub workflows [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Performance regression and stuck jobs due to gcs-connector v3 upgrade [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Performance regression and stuck jobs due to gcs-connector v3 upgrade [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Use curl -fsSL --retry 5 in website/Dockerfile [beam] jrmccluskey (via GitHub) via github
2026/11/09 Re: [PR] Synchronize namespace creation in RecordWriterManager and apply targetParallelism=1 in IcebergCatalogBaseIT [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Increase Gradle wrapper networkTimeout and retry wrapper bootstrap on cache miss [beam] damccorm (via GitHub) via github
2026/11/09 [PR] [Java] Add --awsCredentialsSecretManager and --awsAccessKeyId/--awsSecretAccessKey/--awsSessionToken [beam] shunping (via GitHub) via github
2026/11/09 Re: [PR] [Prism] Advance aggregation stage watermark past emitted accumulating… [beam] codecov[bot] (via GitHub) via github
2026/11/09 [PR] [Java] Add `--awsCredentialsSecretManager` and `--awsAccessKeyId`/`--awsSecretAccessKey`/`--awsSessionToken` [beam] shunping (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Google Cloud Storage Sink not working with unbounded pcollection using Sliding window and GrouByKey [beam] github-actions[bot] (via GitHub) via github
2026/11/09 Re: [PR] Adds bytes read reporting for SDF. [beam] acrites (via GitHub) via github
2026/11/09 [PR] [Java] Add SecretCredentialsProvider to resolve AWS credentials from a secret manager [beam] shunping (via GitHub) via github
2026/11/09 Re: [PR] [BEAM-41079] Fix StringCompiler classpath resolution[BEAM-41079] Fix StringCompiler classpath resolution [beam] Tarun4201 (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Use the default Redistribute key count for cross-language KafkaIO reads [beam] jrmccluskey (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Python ReadFromKafka(redistribute=True) overrides the Java default for num keys, leaks timer state on Flink [beam] jrmccluskey (via GitHub) via github
2026/11/09 Re: [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Harden testcontainers startup retry handling in cloudsql_it_test and rag test_utils [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] [Python] Fast-path _IntervalWindowBase.__init__ for int and Timestamp inputs [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Adds bytes read reporting for SDF. [beam] scwhittle (via GitHub) via github
2026/11/09 [PR] Use the default Redistribute key count for cross-language KafkaIO reads [beam] PDGGK (via GitHub) via github
2026/11/09 Re: [PR] Configure failed stream connects before unblocking handover in Windmill gRPC stream tests [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Fixes some bugs in WindmillMapViaMultimap. [beam] scwhittle (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Retry Pub/Sub topic and subscription creation in StreamingWordCountIT.setUp [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Run StorageApiSinkRowUpdateIT with targetParallelism=1 to avoid concurrent StreamWriter closure on table creation [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Python] Use __name__ prefix in code_object_pickler_test [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Harden testcontainers startup retry handling in cloudsql_it_test and rag test_utils [beam] damccorm (via GitHub) via github
2026/11/09 [PR] Harden testcontainers startup retry handling in cloudsql_it_test and rag test_utils [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Configure failed stream connects before unblocking handover in Windmill gRPC stream tests [beam] damccorm (via GitHub) via github
2026/11/09 [PR] Configure failed stream connects before unblocking handover in Windmill gRPC stream tests [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673) [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] [RunInference] Pass the device to a custom inference_fn in HuggingFaceModelHandlerTensor [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Bump github.com/testcontainers/testcontainers-go from 0.44.0 to 0.45.0 in /sdks [beam] stankiewicz (via GitHub) via github
2026/11/09 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.19 to 1.23.21 in /sdks [beam] stankiewicz (via GitHub) via github
2026/11/09 Re: [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] github-actions[bot] (via GitHub) via github
2026/11/09 [PR] [Python] Fast-path _IntervalWindowBase.__init__ for int and Timestamp inputs [beam] damccorm (via GitHub) via github
2026/11/09 [PR] [YAML] Skip non-identifier and keyword field names when binding Python expression variables [beam] Abhi2939 (via GitHub) via github
2026/11/09 Re: [PR] Retry transient 5xx GitHub API errors in pr-bot getGitHubClient [beam] github-actions[bot] (via GitHub) via github
2026/11/09 Re: [PR] Synchronize namespace creation in RecordWriterManager and apply targetParallelism=1 in IcebergCatalogBaseIT [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] github-actions[bot] (via GitHub) via github
2026/11/09 Re: [PR] Retry catalog setup in IcebergCatalogBaseIT and IcebergCdcWriteBaseIT [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Batch amqsput messages and increase subscriber timeout in xlang_jmsio_it_test [beam] codecov[bot] (via GitHub) via github
2026/11/09 Re: [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] damccorm (via GitHub) via github
2026/11/09 [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Python] Fast-path _IntervalWindowBase.__init__ for int and Timestamp inputs [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Configure mavenCentralMirrorUrl in buildSrc/settings.gradle.kts pluginManagement [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Go] Support context.Context in register.CombinerN methods [beam] jonathansudhakar1 (via GitHub) via github
2026/11/09 [PR] Retry catalog setup in IcebergCatalogBaseIT and IcebergCdcWriteBaseIT [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Enable uniform retry strategy and batch fallback retries in GcsUtilV2 [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] github-actions[bot] (via GitHub) via github
2026/11/09 Re: [PR] Use curl -fsSL --retry 5 in website/Dockerfile [beam] github-actions[bot] (via GitHub) via github
2026/11/09 Re: [PR] Increase default readTimeout to 60s in JmsIOIT [beam] github-actions[bot] (via GitHub) via github
2026/11/09 [PR] Retry transient 5xx GitHub API errors in pr-bot getGitHubClient [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Retry transient 5xx GitHub API errors in pr-bot getGitHubClient [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] The PreCommit Website job is flaky [beam] damccorm (via GitHub) via github
2026/11/09 [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: SpannerIO Change Streams may skip ChildPartitionsRecord when advancing tracker to artificial query end timestamp [beam] damccorm (via GitHub) via github
2026/11/09 Re: [PR] Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: DaskRunner `DaskBagWindowedIterator` materializes entire dataset into memory causing OOM [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: SpannerIO Change Streams may skip ChildPartitionsRecord when advancing tracker to artificial query end timestamp [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: DaskRunner `DaskBagWindowedIterator` materializes entire dataset into memory causing OOM [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] [Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] The PreCommit Website job is flaky [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] The PreCommit Website Stage GCS job is flaky [beam] damccorm (via GitHub) via github
2026/11/09 Re: [I] The PreCommit Website Stage GCS job is flaky [beam] damccorm (via GitHub) via github