github  

Messages by Thread

• • Re: [PR] Feat: new cleaning rule to orphaned subscriptions [beam] via GitHub
• [PR] Enhance Python Timestamp to be precision-variable up to nanos, and map it to Timestamp logical type [beam] via GitHub
  • Re: [PR] Enhance Python Timestamp to be precision-variable up to nanos, and map it to Timestamp logical type [beam] via GitHub
  • Re: [PR] Enhance Python Timestamp to be precision-variable up to nanos, and map it to Timestamp logical type [beam] via GitHub
  • Re: [PR] Enhance Python Timestamp to be precision-variable up to nanos, and map it to Timestamp logical type [beam] via GitHub
  • Re: [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: [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] via GitHub
• [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
  • Re: [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
  • Re: [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
  • Re: [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
  • Re: [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
  • Re: [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
  • Re: [PR] Changes SplittableDoFn to call TruncateRestriction on drain [beam] via GitHub
• [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
  • Re: [PR] Fix Update Python Dependencies [beam] via GitHub
• Re: [I] Add an Arrow Flight based Java IO connector [beam] via GitHub
• Re: [PR] fix xlang KafkaIO perf test expansion service Java version [beam] via GitHub
• Re: [PR] Make FirestoreV1 Transform bases public for worker access [beam] via GitHub
• [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
  • Re: [PR] fix AddFilesIT filter for BigLake [beam] via GitHub
• [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam] via GitHub
  • Re: [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam] via GitHub
  • Re: [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam] via GitHub
  • Re: [I] The pip in /sdks/python/apache_beam/testing/benchmarks/chicago_taxi for notebook - Update #1490599843 job is flaky [beam] via GitHub
• [PR] Update ruff and pyrefly dependencies [beam] via GitHub
  • Re: [PR] Update ruff and pyrefly dependencies [beam] via GitHub
  • Re: [PR] Update ruff and pyrefly dependencies [beam] via GitHub
  • Re: [PR] Update ruff and pyrefly dependencies [beam] via GitHub
  • Re: [PR] Update ruff and pyrefly dependencies [beam] via GitHub
• [PR] Bump lower and upper bounds for pyarrow, remove unnecessary CVE hotfix [beam] via GitHub
  • Re: [PR] Bump lower and upper bounds for pyarrow, remove unnecessary CVE hotfix [beam] via GitHub
  • Re: [PR] Bump lower and upper bounds for pyarrow + related dependencies, remove unnecessary CVE hotfix [beam] via GitHub
  • Re: [PR] Bump lower and upper bounds for pyarrow + related dependencies, remove unnecessary CVE hotfix [beam] via GitHub
  • Re: [PR] Bump lower and upper bounds for pyarrow + related dependencies, remove unnecessary CVE hotfix [beam] via GitHub
  • Re: [PR] Bump lower and upper bounds for pyarrow + related dependencies, remove unnecessary CVE hotfix [beam] via GitHub
  • Re: [PR] Bump lower and upper bounds for pyarrow + related dependencies, remove unnecessary CVE hotfix [beam] via GitHub
• [PR] [Docs] Add unbounded source guidance to the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Add unbounded source guidance to the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Add unbounded source guidance to the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] via GitHub
  • Re: [PR] [Docs] Document UnboundedSource in the Python I/O connector guide [beam] via GitHub
• [PR] [Gemini] Fix pyrefly check unexpected-keyword [beam] via GitHub
  • Re: [PR] [Gemini] Fix pyrefly check unexpected-keyword [beam] via GitHub
  • Re: [PR] [Gemini] Fix pyrefly check unexpected-keyword [beam] via GitHub
  • Re: [PR] [Gemini] Fix pyrefly check unexpected-keyword [beam] via GitHub
• [I] [Task]: Improve Beam's compliance with Pyrefly checks [beam] via GitHub
  • Re: [I] [Task]: Improve Beam's compliance with Pyrefly checks [beam] via GitHub
  • Re: [I] [Task]: Improve Beam's compliance with Pyrefly checks [beam] via GitHub
• [PR] Replace non-PEP 585 types in watch.py [beam] via GitHub
  • Re: [PR] Replace non-PEP 585 types in watch.py [beam] via GitHub
  • Re: [PR] Replace non-PEP 585 types in watch.py [beam] via GitHub
  • Re: [PR] Replace non-PEP 585 types in watch.py [beam] via GitHub
  • Re: [PR] Replace non-PEP 585 types in watch.py [beam] via GitHub
  • Re: [PR] Replace non-PEP 585 types in watch.py [beam] via GitHub
• Re: [I] [Bug]: Postgres not connecting in apache beam with go sdk [beam] via GitHub
• Re: [I] [Bug]: Some methods on DeferredSeries and DeferredDataFrame don't work right when returning single items [beam] via GitHub
• Re: [I] [Bug]: Dataflow keeps retrying to obtain an already deleted BigQuery dataset [beam] via GitHub
• Re: [I] [Feature Request]: Splittable DoFn Kafka reader in Python [beam] via GitHub
• Re: [I] [Bug][prism]: Support receiving Java's CoGBKList Result [beam] via GitHub
• Re: [I] [Bug]: pickle_library option is ignored [beam] via GitHub
• Re: [I] [Java] context.Output within try catch can catch errors from downstream transforms [beam] via GitHub
• [I] [Failing Test]: BigQueryStreamingInsertsErrorHandling test is flaky [beam] via GitHub
  • Re: [I] [Failing Test]: BigQueryStreamingInsertsErrorHandling test is flaky [beam] via GitHub
• [PR] Bump scikit-learn from 1.0.2 to 1.5.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam] via GitHub
  • Re: [PR] Bump scikit-learn from 1.0.2 to 1.5.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam] via GitHub
  • Re: [PR] Bump scikit-learn from 1.0.2 to 1.5.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam] via GitHub
  • Re: [PR] Bump scikit-learn from 1.0.2 to 1.5.0 in /sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline [beam] via GitHub
• [PR] Bump golang.org/x/oauth2 from 0.7.0 to 0.27.0 in /playground/backend [beam] via GitHub
  • Re: [PR] Bump golang.org/x/oauth2 from 0.7.0 to 0.27.0 in /playground/backend [beam] via GitHub
  • Re: [PR] Bump golang.org/x/oauth2 from 0.7.0 to 0.27.0 in /playground/backend [beam] via GitHub
• [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py310 [beam] via GitHub
• [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py311 [beam] via GitHub
• [PR] Fix flaky AsyncWrapper reset_state test [beam] via GitHub
  • Re: [PR] Fix flaky AsyncWrapper reset_state test [beam] via GitHub
  • Re: [PR] Fix flaky AsyncWrapper reset_state test on Python 3.14 [beam] via GitHub
  • Re: [PR] Fix flaky AsyncWrapper reset_state test on Python 3.14 [beam] via GitHub
  • Re: [PR] Fix flaky AsyncWrapper reset_state test on Python 3.14 [beam] via GitHub
  • Re: [PR] Fix flaky AsyncWrapper reset_state test on Python 3.14 [beam] via GitHub
• [PR] Bump actions/stale from 10 to 11 [beam] via GitHub
  • Re: [PR] Bump actions/stale from 10 to 11 [beam] via GitHub
  • Re: [PR] Bump actions/stale from 10 to 11 [beam] via GitHub
• [PR] Bump github.com/aws/smithy-go from 1.27.4 to 1.27.5 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/smithy-go from 1.27.4 to 1.27.5 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/smithy-go from 1.27.4 to 1.27.5 in /sdks [beam] via GitHub
• [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.9.0 [beam] via GitHub
• [PR] Bump github.com/moby/moby/client from 0.5.0 to 0.5.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/moby/moby/client from 0.5.0 to 0.5.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/moby/moby/client from 0.5.0 to 0.5.1 in /sdks [beam] via GitHub
• [PR] Bump com.diffplug.spotless from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.9.0 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.9.0 [beam] via GitHub
• [PR] Bump keras from 3.12.3 to 3.13.2 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump keras from 3.12.3 to 3.13.2 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump keras from 3.12.3 to 3.13.2 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump keras from 3.12.3 to 3.13.2 in /sdks/python/container/ml/py310 [beam] via GitHub
• [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py310 [beam] via GitHub
• [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/py313 [beam] via GitHub
  • Re: [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/py313 [beam] via GitHub
  • Re: [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/py313 [beam] via GitHub
• [PR] Bump torch from 2.12.0 to 2.13.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] via GitHub
  • Re: [PR] Bump torch from 2.12.0 to 2.13.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] via GitHub
  • Re: [PR] Bump torch from 2.12.0 to 2.13.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] via GitHub
• [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py312 [beam] via GitHub
  • Re: [PR] Bump nltk from 3.9.4 to 3.10.0 in /sdks/python/container/ml/py312 [beam] via GitHub
• [PR] Bump golang.org/x/net from 0.54.0 to 0.55.0 in /.test-infra/mock-apis [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.54.0 to 0.55.0 in /.test-infra/mock-apis [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.54.0 to 0.55.0 in /.test-infra/mock-apis [beam] via GitHub
• [PR] Decorrelate sub-queries using normalizeForVolcano pass [beam] via GitHub
  • Re: [PR] Decorrelate sub-queries using normalizeForVolcano pass [beam] via GitHub
• [PR] Add parser conformance resolution and logical plan parsing [beam] via GitHub
  • Re: [PR] Add parser conformance resolution and logical plan parsing [beam] via GitHub
• [PR] Add SINGLE_VALUE aggregate function [beam] via GitHub
  • Re: [PR] Add SINGLE_VALUE aggregate function [beam] via GitHub
• Re: [PR] Fix bundle finalizer callbacks for SDF [beam] via GitHub
  • Re: [PR] Fix bundle finalizer callbacks for SDF [beam] via GitHub
  • Re: [PR] Fix bundle finalizer callbacks for SDF [beam] via GitHub
  • Re: [PR] Fix bundle finalizer callbacks for SDF [beam] via GitHub
• Re: [I] The PostCommit Javadoc job is flaky [beam] via GitHub
• [PR] sdks/java: re-enable nullness checks in WithKeys [beam] via GitHub
  • Re: [PR] sdks/java: re-enable nullness checks in WithKeys [beam] via GitHub
  • Re: [PR] sdks/java: re-enable nullness checks in WithKeys [beam] via GitHub
  • Re: [PR] sdks/java: re-enable nullness checks in WithKeys [beam] via GitHub
• Re: [PR] [Python] Refactor MatchContinuously to use Watch [beam] via GitHub
  • Re: [PR] [Python] Refactor MatchContinuously to use Watch [beam] via GitHub
• [PR] Bump torch from 2.7.1 to 2.13.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump torch from 2.7.1 to 2.13.0 in /sdks/python/container/ml/py310 [beam] via GitHub
  • Re: [PR] Bump torch from 2.7.1 to 2.13.0 in /sdks/python/container/ml/py310 [beam] via GitHub
• [PR] feat: add MongoDB driver handshake metadata to MongoDBResourceManager [beam] via GitHub
  • Re: [PR] feat: add MongoDB driver handshake metadata to MongoDBResourceManager [beam] via GitHub
  • Re: [PR] feat: add MongoDB driver handshake metadata for Java-based client connections [beam] via GitHub
  • Re: [PR] feat: add MongoDB driver handshake metadata for Java-based client connections [beam] via GitHub
  • Re: [PR] feat: add MongoDB driver handshake metadata for Java-based client connections [beam] via GitHub
  • Re: [PR] feat: add MongoDB driver handshake metadata for Java-based client connections [beam] via GitHub
  • Re: [PR] feat: add MongoDB driver handshake metadata for Java-based client connections [beam] via GitHub
• Re: [I] [yaml] Add Beam YAML Troubleshooting Guide [beam] via GitHub
  • Re: [I] [yaml] Add Beam YAML Troubleshooting Guide [beam] via GitHub
• Re: [I] [yaml] Add resource hints to Beam YAML syntax [beam] via GitHub
  • Re: [I] [yaml] Add resource hints to Beam YAML syntax [beam] via GitHub
• Re: [I] [Bug]: DirectRunner fails after grouping into batches, and applying flat map with assertion error [beam] via GitHub
  • Re: [I] [Bug]: DirectRunner fails after grouping into batches, and applying flat map with assertion error [beam] via GitHub
• Re: [I] [Feature]: Custom timestamps for Kinesis IO reader (currently always approx publish timestamp) [beam] via GitHub
  • Re: [I] [Feature]: Custom timestamps for Kinesis IO reader (currently always approx publish timestamp) [beam] via GitHub
• Re: [I] [Test Fix]: Reduce size of Fhir IO integration tests [beam] via GitHub
  • Re: [I] [Test Fix]: Reduce size of Fhir IO integration tests [beam] via GitHub
• Re: [I] [Bug]: Beam roles infra - Unable to run the Dataflow TPU example [beam] via GitHub
  • Re: [I] [Bug]: Beam roles infra - Unable to run the Dataflow TPU example [beam] via GitHub
• [PR] Pin Playground kafka-emulator to kafka-clients 2.4.1 [beam] via GitHub
  • Re: [PR] Pin Playground kafka-emulator to kafka-clients 2.4.1 [beam] via GitHub
  • Re: [PR] Pin Playground kafka-emulator to kafka-clients 2.4.1 [beam] via GitHub
  • Re: [PR] Pin Playground kafka-emulator to kafka-clients 2.4.1 [beam] via GitHub
• [PR] Skip IcebergPerformanceTest until next release [beam] via GitHub
  • Re: [PR] Skip IcebergPerformanceTest until next release [beam] via GitHub
  • Re: [PR] Skip IcebergPerformanceTest until next release [beam] via GitHub
  • Re: [PR] Skip IcebergPerformanceTest until next release [beam] via GitHub
  • Re: [PR] Skip IcebergPerformanceTest until next release [beam] via GitHub
• [PR] Bump ray from 2.55.1 to 2.56.0 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump ray from 2.55.1 to 2.56.0 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump ray from 2.55.1 to 2.56.0 in /sdks/python/container/ml/py311 [beam] via GitHub
• [PR] Bump httplib2 from 0.31.2 to 0.32.0 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump httplib2 from 0.31.2 to 0.32.0 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump httplib2 from 0.31.2 to 0.32.0 in /sdks/python/container/ml/py311 [beam] via GitHub
  • Re: [PR] Bump httplib2 from 0.31.2 to 0.32.0 in /sdks/python/container/ml/py311 [beam] via GitHub
• Re: [PR] [OpenTelemetry] Add tracing support to KafkaIO [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add tracing support to KafkaIO [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add tracing support to KafkaIO [beam] via GitHub

• Earlier messages
• Later messages