github  

Messages by Date

• 2026/11/10 [PR] [Python] Optimize PerWindowInvoker window argument caching and DoFn param identity checks [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] Reuse embedded FnHarness environment and isolate job IDs in Flink portable execution tests [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Fix the DataFrame cov and corr diagonals and corr of a constant column [beam] damccorm (via GitHub) via github
• 2026/11/10 [PR] [Flink] Group partial combines by the structural value of the key [beam] pkuzmickas (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 [PR] [Flink] Spread start channels of consecutive senders in batch Reshuffle [beam] pkuzmickas (via GitHub) via github
• 2026/11/10 [I] [Bug]: [SolaceIO] Reader fails with StaleSessionException and cannot recover after broker disconnect [beam] stankiewicz (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] Run Python PostCommit vllmTests and tensorRTtests in us-west1 to avoid us-central1 T4 GPU quota exhaustion [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize AvroRowWriter.tell, BigQueryWrapper.insert_rows, and _split_table_spec [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize _IntervalWindowBase.__eq__ and __hash__ [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] Check cancelFlag when PipelineResult.waitUntilFinish throws RuntimeException in BeamEnumerableConverter [beam] damccorm (via GitHub) via github
• 2026/11/10 [PR] Check cancelFlag when PipelineResult.waitUntilFinish throws RuntimeException in BeamEnumerableConverter [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.9.0 [beam] dependabot[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.9.0 [beam] derrickaw (via GitHub) via github
• 2026/11/10 Re: [PR] Bump cloud.google.com/go/bigquery from 1.86.1 to 1.86.2 in /sdks [beam] derrickaw (via GitHub) via github
• 2026/11/10 Re: [PR] Bump golang.org/x/oauth2 from 0.37.0 to 0.38.0 in /sdks [beam] derrickaw (via GitHub) via github
• 2026/11/10 Re: [PR] Batch amqsput messages and increase subscriber timeout in xlang_jmsio_it_test [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize WindowedValue.__hash__ and HomogeneousWindowedBatch.from_windowed_values [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] Harden Python testcontainers startup retry cleanup with cleanup_testcontainer_on_retry [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Optimize Count, Top, Sample, ToList, and ConcatList CombineFns [beam] damccorm (via GitHub) via github
• 2026/11/10 Re: [I] [Bug]: BoundedSources and SDFs are not working with the BundleBasedDirectRunner [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [I] [Bug]: Beam SDK throws `NoClassDefFoundError` using SparkRunner in Dataproc 2.1 (Java 11) [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [I] [Feature Request]: Iceberg IO Hash Distribution Mode Support for Spark Based Runners [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Java] Bound pending Watch results per poll [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Dataflow Java] Extend work item lease while DoFn.setup runs in batch worker [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 Re: [PR] [Python] Default WriteToJson double_precision to 15 to avoid silently rounding floats [beam] github-actions[bot] (via GitHub) via github
• 2026/11/10 [PR] [Python] Default WriteToJson double_precision to 15 to avoid silently rounding floats [beam] Abhi2939 (via GitHub) via github
• 2026/11/10 Re: [I] [Bug]: [Python] WriteToJson silently rounds floats to 10 decimal places [beam] Abhi2939 (via GitHub) via github
• 2026/11/10 Re: [I] [Bug]: [Python] WriteToJson silently rounds floats to 10 decimal places [beam] Abhi2939 (via GitHub) via github
• 2026/11/09 Re: [I] [Feature Request]: [YAML] Support error_handling dead-letter output on ReadFromCsv and ReadFromJson [beam] codewarnab (via GitHub) via github
• 2026/11/09 Re: [I] [Bug]: [Python] WriteToJson silently rounds floats to 10 decimal places [beam] jk-shah (via GitHub) via github
• 2026/11/09 Re: [I] [Bug]: local-env-setup.sh fails on M1 mac [beam] ayush-builds-stuff (via GitHub) via github
• 2026/11/09 Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.9.0 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.7 to 1.47.8 in /sdks [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Bump golang.org/x/oauth2 from 0.37.0 to 0.38.0 in /sdks [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Bump google.golang.org/api from 0.310.0 to 0.311.0 in /sdks [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Bump cloud.google.com/go/bigquery from 1.86.1 to 1.86.2 in /sdks [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Bump golang.org/x/sync from 0.24.0 to 0.25.0 in /sdks [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Bump gradle-wrapper from 8.14.3 to 9.9.0 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.47.7 to 1.47.8 in /sdks [beam] dependabot[bot] (via GitHub) via github
• 2026/11/09 [PR] Bump golang.org/x/sync from 0.24.0 to 0.25.0 in /sdks [beam] dependabot[bot] (via GitHub) via github
• 2026/11/09 [PR] Bump cloud.google.com/go/bigquery from 1.86.1 to 1.86.2 in /sdks [beam] dependabot[bot] (via GitHub) via github
• 2026/11/09 [PR] Bump google.golang.org/api from 0.310.0 to 0.311.0 in /sdks [beam] dependabot[bot] (via GitHub) via github
• 2026/11/09 [PR] Bump golang.org/x/oauth2 from 0.37.0 to 0.38.0 in /sdks [beam] dependabot[bot] (via GitHub) via github
• 2026/11/09 [PR] Bump gradle-wrapper from 8.14.3 to 9.9.0 [beam] dependabot[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Run Python PostCommit vllmTests and tensorRTtests in us-west1 to avoid us-central1 T4 GPU quota exhaustion [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Check holdTimestamp on overwritten event-time timers and honor cleared processing-time timers in Prism [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Run Python PostCommit vllmTests and tensorRTtests in us-west1 to avoid us-central1 T4 GPU quota exhaustion [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Run Python PostCommit vllmTests and tensorRTtests in us-west1 to avoid us-central1 T4 GPU quota exhaustion [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Check holdTimestamp on overwritten event-time timers and honor cleared processing-time timers in Prism [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Check holdTimestamp on overwritten event-time timers and honor cleared processing-time timers in Prism [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Go] Fix metrics incremented in Setup not being recalled [beam] xh123637 (via GitHub) via github
• 2026/11/09 Re: [PR] Move BundleLifter from Iceberg to sdk/util [beam] ahmedabu98 (via GitHub) via github
• 2026/11/09 Re: [PR] Use current timestamp for streaming ReadFromIcebergCDC to_timestamp in YAML ITs [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Check BackgroundCachingJob.is_done_or_running atomically under _result_lock [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Use current timestamp for streaming ReadFromIcebergCDC to_timestamp in YAML ITs [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Use current timestamp for streaming ReadFromIcebergCDC to_timestamp in YAML ITs [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Check BackgroundCachingJob.is_done_or_running atomically under _result_lock [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Check BackgroundCachingJob.is_done_or_running atomically under _result_lock [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Avoid false-positive CheckGrafanaDataFreshness failures during quiet GitHub issue windows [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Avoid false-positive CheckGrafanaDataFreshness failures during quiet GitHub issue windows [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Test Health] Avoid shaded sql:jdbc fat jar on sql:iceberg testRuntimeClasspath [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Hold new-schema rows in UpdateSchemaDoFn until recognition window completes [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Hold new-schema rows in UpdateSchemaDoFn until recognition window completes [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Test Health] Avoid shaded sql:jdbc fat jar on sql:iceberg testRuntimeClasspath [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] [Test Health] Avoid shaded sql:jdbc fat jar on sql:iceberg testRuntimeClasspath [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Attach RunInference model_identifier only to the inference ParDo with exception handling [beam] tvalentyn (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize WindowedValue.__hash__ and HomogeneousWindowedBatch.from_windowed_values [beam] tvalentyn (via GitHub) via github
• 2026/11/09 Re: [PR] Retry transient 5xx GitHub API errors in pr-bot getGitHubClient [beam] shunping (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Fix the DataFrame cov and corr diagonals and corr of a constant column [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [I] [Bug]: DataFrame API cov and corr diagonals ignore ddof and min_periods, and corr fails on a constant column [beam] anishmehta24 (via GitHub) via github
• 2026/11/09 [PR] [Python] Fix the DataFrame cov and corr diagonals and corr of a constant column [beam] anishmehta24 (via GitHub) via github
• 2026/11/09 [I] [Bug]: DataFrame API cov and corr diagonals ignore ddof and min_periods, and corr fails on a constant column [beam] anishmehta24 (via GitHub) via github
• 2026/11/09 Re: [PR] Clone TransformWithState stateful processors across sibling streaming queries [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Harden PortableTimersExecutionTest against PreCommit Flink load [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] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Retry catalog setup in IcebergCatalogBaseIT and IcebergCdcWriteBaseIT [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Retry catalog setup in IcebergCatalogBaseIT and IcebergCdcWriteBaseIT [beam] codecov[bot] (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 Re: [PR] Retry Pub/Sub topic and subscription creation in StreamingWordCountIT.setUp [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Batch amqsput messages and increase subscriber timeout in xlang_jmsio_it_test [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Enable uniform retry strategy and batch fallback retries in GcsUtilV2 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Enable uniform retry strategy and batch fallback retries in GcsUtilV2 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Enable uniform retry strategy and batch fallback retries in GcsUtilV2 [beam] codecov[bot] (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] Wait for datanode SSH readiness before starting HDFS in hdfs-multi-datanode-cluster.yml [beam] github-actions[bot] (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] Port ReadSpannerSchemaTest off DoFnTester [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [YAML] Skip non-identifier and keyword field names when binding Python expression variables [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Fast-path _IntervalWindowBase.__init__ for int and Timestamp inputs [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 [PR] Port ReadSpannerSchemaTest off DoFnTester [beam] Rishavbhattarai (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] Use curl -fsSL --retry 5 when installing docker-compose in workflows [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Increase Firestore test setup Future.get timeout from 10s to 60s in BaseFirestoreIT [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [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 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [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] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] Clone TransformWithState stateful processors across sibling streaming queries [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Clone TransformWithState stateful processors across sibling streaming queries [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [beam] codecov[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer [beam] prodriguezdefino (via GitHub) via github
• 2026/11/09 Re: [PR] [#36841] Announce Spark 4 Structured Streaming runner streaming support in CHANGES.md [beam] Abacn (via GitHub) via github
• 2026/11/09 Re: [I] [Task]: Spark 4 streaming runner, support Redistribute [beam] Abacn (via GitHub) via github
• 2026/11/09 Re: [PR] [#40950] Spark Structured Streaming runner: translate Redistribute like Reshuffle [beam] Abacn (via GitHub) via github
• 2026/11/09 Re: [I] Element type inference doesn't work for multi-output DoFns [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Remove the unused Python RPC DirectRunner [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Document that query results can be read with the BigQuery storage API [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 Re: [PR] Harden testcontainers startup retry handling in cloudsql_it_test and rag test_utils [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Build test infra for end-to-end streaming test in Python SDK [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] ./gradlew :goIntegrationTests fails with BeamModulePlugin error [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Upgrade Gradle Build Compatibility for Gradle 9 and JDK 25 [beam] alisha-1000 (via GitHub) via github
• 2026/11/09 Re: [PR] Upgrade Gradle Build Compatibility for Gradle 9 and JDK 25 [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Use curl -fsSL --retry 5 when installing docker-compose in workflows [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [I] Remove duplicate content in BeamBigQuerySqlDialect after updating Calcite version [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: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [YAML] Fix mapping expression validation, named chain outputs, and er… [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [I] JDBC driver load errors :jdbc:calcite and :jdbc:beam [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] DockerJobBundleFactory's ProvisionInfo is empty. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Go check for IsWorkerCompatibleBinary is wrong [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Make the spark runner not serialize data unless spark is spilling to disk [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Add support for remaining data types in python RowCoder [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] Configure mavenCentralMirrorUrl in buildSrc/settings.gradle.kts pluginManagement [beam] Abacn (via GitHub) via github
• 2026/11/09 Re: [PR] Configure mavenCentralMirrorUrl in buildSrc/settings.gradle.kts pluginManagement [beam] Abacn (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 [PR] [Python] Optimize IntervalWindow.__lt__, intersects, and union using microsecond fields [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] [Python] Optimize FixedWindows, SlidingWindows, and Sessions assign with microsecond arithmetic [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Java] Add `SecretCredentialsProvider` to resolve AWS credentials [beam] shunping (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] Harden testcontainers startup retry handling in cloudsql_it_test and rag test_utils [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Java] Add SecretCredentialsProvider to resolve AWS credentials from a secret manager [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] Add CHANGES function to Beam SQL [beam] ahmedabu98 (via GitHub) via github
• 2026/11/09 Re: [PR] Configure mavenCentralMirrorUrl in buildSrc/settings.gradle.kts pluginManagement [beam] github-actions[bot] (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: [PR] [Java] Add SecretCredentialsProvider to resolve AWS credentials from a secret manager [beam] github-actions[bot] (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 Re: [I] Some DataFrame operations yield incorrect proxies [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Dataflow and KafkaIO or KinesisIO has erratic watermark progress due to ReaderCache timeouts [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize BigQueryWriteFn row size estimation and table ref parsing [beam] damccorm (via GitHub) via github
• 2026/11/09 [PR] [YAML] Fix mapping expression validation, named chain outputs, and er… [beam] LibenHailu (via GitHub) via github
• 2026/11/09 Re: [I] Move Portable Runner and other of reference runner. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] PortableRunner should run dockerized SDK workers [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Add support for dynamic worker re-balancing when reading BigQuery data using Cloud Dataflow [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Support deflate (zlib) in CompressedFile [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] TfIdfTest should not be marked ValidatesRunner [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Remove refcounts from the Python SDK [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Add ValueState in Python sdk [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Performance Tests Results Analysis and Regression Detection [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Modify run_validatescontainer.sh in Python sdk to allow validating user-provided containers. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Grouping By LogicalTypes is not supported [beam] damccorm (via GitHub) via github
• 2026/11/09 [I] [Bug]: [YAML] Bugs in mapping expression validation, named chain outputs, and error formatting [beam] LibenHailu (via GitHub) via github
• 2026/11/09 Re: [I] Colab examples for aggregation transforms (Python) [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] Remote sources provide insufficient metadata about relative sizes of splits [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] TextIO.Write silently fails in python when writing to GCS streaming. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Remove duplicate content in BeamBigQuerySqlDialect after updating Calcite version [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Colab examples for element-wise transforms (Python) [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Equality tests in coders.py are broken [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Detect unexported fields in unregistered types for better error messages [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Upgrade gradle-versions-plugin to 0.20.0 [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] PipelineTranslationTest.testProtoAgainstRehydrated() over-validates translated proto structure [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] FileIOTest.testMatchWatchForNewFiles flakey in java presubmit [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Upgrade gradle-versions-plugin to 0.20.0 [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] BundleBasedDirectRunner fails with recent side input changes [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Handle map encoding better. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Run tests against shaded JAR [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] DockerJobBundleFactory's ProvisionInfo is empty. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Go check for IsWorkerCompatibleBinary is wrong [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Remove experimental annotation from stable transforms in Java BigTableIO connector [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Python DirectRunner _PubSubReadEvaluator creates new client per bundle [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]: Parameterized Query support in Go BigQuery IO connector [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] AvroCoder - Support Logical Types [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Move pom generation metadata logic out of build_rules.gradle [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Remove the unused Python RPC DirectRunner [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Incorrect timestamp on merging window outputs. [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Upgrade Bigtable client to 1.3 [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] [Bug]: some examples are not loading in ToB integration tests [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Move pom generation metadata logic out of build_rules.gradle [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] Example of distributed optimization [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] PTransformOverride does not replace side input usage of replaced transform [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] ExecutorServiceParallelExecutorTest#ensureMetricsThreadDoesntLeak in PR #4965 does not pass in gradle [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Support Python ValidatesRunner test against TestDataflowRunner in streaming [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [PR] [Python] Optimize Timestamp and Duration comparison and epoch helpers [beam] github-actions[bot] (via GitHub) via github
• 2026/11/09 Re: [I] fix http_proxy warnings from grpc in tests [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Colab examples for element-wise transforms (Python) [beam] damccorm (via GitHub) via github
• 2026/11/09 Re: [I] Upgrade google-cloud-pubsub to version >=1.4.2 [beam] damccorm (via GitHub) via github

• Earlier messages
• Later messages