github  

Messages by Thread

• • Re: [PR] cherry-pick Free disk space for snapshot job and use correct requirements file (#36681) [beam] via GitHub
• [I] [Feature Request]: Add support for pyarrow >= 19.0.0 [beam] via GitHub
  • Re: [I] [Feature Request]: Add support for pyarrow >= 19.0.0 [beam] via GitHub
• [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
  • Re: [I] [Bug] [python]: Possible race condition when starting many pipelines at the same time [beam] via GitHub
• Re: [I] Auto Inference of JdbcIO#NumPartitions seems to be dead code. [beam] via GitHub
  • Re: [I] Auto Inference of JdbcIO#NumPartitions seems to be dead code. [beam] via GitHub
  • Re: [I] Auto Inference of JdbcIO#NumPartitions seems to be dead code. [beam] via GitHub
• Re: [I] [Task]: Migrate from the Gradle Enterprise plugin to Develocity [beam] via GitHub
  • Re: [I] [Task]: Migrate from the Gradle Enterprise plugin to Develocity [beam] via GitHub
  • Re: [I] [Task]: Migrate from the Gradle Enterprise plugin to Develocity [beam] via GitHub
• Re: [I] [Feature Request]: Add custom counters tracking bytes read and written from the Google Cloud Storage in the GcsFileSystem [beam] via GitHub
  • Re: [I] [Feature Request]: Add custom counters tracking bytes read and written from the Google Cloud Storage in the GcsFileSystem [beam] via GitHub
  • Re: [I] [Feature Request]: Add custom counters tracking bytes read and written from the Google Cloud Storage in the GcsFileSystem [beam] via GitHub
• Re: [I] [Bug]: Exception from Downstream DoFn suppressed if upstream DoFn catches it on Dataflow Runner [beam] via GitHub
• Re: [I] [Task]: Use google-github-actions/auth@v2 to authenticate with google cloud SA [beam] via GitHub
  • Re: [I] [Task]: Use google-github-actions/auth@v2 to authenticate with google cloud SA [beam] via GitHub
  • Re: [I] [Task]: Use google-github-actions/auth@v2 to authenticate with google cloud SA [beam] via GitHub
• Re: [I] [Feature Request]: Support int32 for properties of Cross lang transformations written in Java [beam] via GitHub
  • Re: [I] [Feature Request]: Support int32 for properties of Cross lang transformations written in Java [beam] via GitHub
• Re: [PR] BeamRowWrapper [beam] via GitHub
  • Re: [PR] BeamRowWrapper [beam] via GitHub
• Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
• Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
  • Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
  • Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
  • Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
  • Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
  • Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
  • Re: [PR] fix(iceberg): prevent premature FileIO closure in RecordWriter [beam] via GitHub
• Re: [PR] Kerberos auth python [beam] via GitHub
  • Re: [PR] Kerberos auth python [beam] via GitHub
• Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
  • Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
  • Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
  • Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
  • Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
  • Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
  • Re: [PR] Added flag for overriding artifact hostname [beam] via GitHub
• Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
  • Re: [PR] Remove `gradle-wrapper.jar` from source tree [beam] via GitHub
• Re: [I] [Failing Test]: beam_PostCommit_TransformService_Direct is permared since October 3 [beam] via GitHub
  • Re: [I] [Failing Test]: beam_PostCommit_TransformService_Direct is permared since October 3 [beam] via GitHub
  • Re: [I] [Failing Test]: beam_PostCommit_TransformService_Direct is permared since October 3 [beam] via GitHub
• Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] via GitHub
  • Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] via GitHub
  • Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] via GitHub
  • Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] via GitHub
  • Re: [I] [Feature Request]: Add Support for Python 3.14 free threading [beam] via GitHub
• Re: [PR] [OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions [beam] via GitHub
• [I] [Feature Request]: AvroIO write improvement with number of shards [beam] via GitHub
  • Re: [I] [Feature Request]: AvroIO write improvement with number of shards [beam] via GitHub
  • Re: [I] [Feature Request]: AvroIO write improvement with number of shards [beam] via GitHub
• [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
  • Re: [PR] Support newer versions of pyarrow. [beam] via GitHub
• [PR] Bump cloud.google.com/go/storage from 1.57.1 to 1.57.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/storage from 1.57.1 to 1.57.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/storage from 1.57.1 to 1.57.2 in /sdks [beam] via GitHub
• [PR] Bump google.golang.org/grpc from 1.76.0 to 1.77.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.76.0 to 1.77.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.76.0 to 1.77.0 in /sdks [beam] via GitHub
• [PR] Bump mypy-protobuf from 3.5.0 to 3.7.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Bump mypy-protobuf from 3.5.0 to 3.7.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Bump mypy-protobuf from 3.5.0 to 3.7.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Bump mypy-protobuf from 3.5.0 to 3.7.0 in /sdks/python [beam] via GitHub
• Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
  • Re: [PR] Iceberg direct write [beam] via GitHub
• [PR] Bump actions/checkout from 5.0.0 to 5.0.1 [beam-starter-java] via GitHub
  • Re: [PR] Bump actions/checkout from 5.0.0 to 5.0.1 [beam-starter-java] via GitHub
• [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] via GitHub
  • Re: [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] via GitHub
  • Re: [I] [Feature Request]: Support Apache Spark 4.x in Beam Spark Runner [beam] via GitHub
• [PR] Support micros isntant in spannerio. [beam] via GitHub
  • Re: [PR] Support micros isntant in spannerio. [beam] via GitHub
  • Re: [PR] Support micros isntant in spannerio. [beam] via GitHub
  • Re: [PR] Support micros isntant in spannerio. [beam] via GitHub
  • Re: [PR] Support beam:logical_type:micros_instant:v1 in SpannerIo. [beam] via GitHub
  • Re: [PR] Support beam:logical_type:micros_instant:v1 in SpannerIo. [beam] via GitHub
  • Re: [PR] Support beam:logical_type:micros_instant:v1 in SpannerIo. [beam] via GitHub
  • Re: [PR] Support beam:logical_type:micros_instant:v1 in SpannerIo. [beam] via GitHub
• [PR] Fix nullness errors in SimpleDoFnRunner and DoFnInvoker [beam] via GitHub
  • Re: [PR] Fix nullness errors in SimpleDoFnRunner and DoFnInvoker [beam] via GitHub
  • Re: [PR] Fix nullness errors in SimpleDoFnRunner and DoFnInvoker [beam] via GitHub
  • Re: [PR] Fix nullness errors in SimpleDoFnRunner and DoFnInvoker [beam] via GitHub
• [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
  • Re: [PR] Fix inconsistent data type in GenericRecord and AvroSchema for AvroWriter [beam] via GitHub
• Re: [PR] Update GCP-BOM, unpin GCP Spanner version [beam] via GitHub
  • Re: [PR] Update GCP-BOM, unpin GCP Spanner version [beam] via GitHub
• [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
  • Re: [PR] Capture element timestamp in DoFnRunners so they do not access mutable fields [beam] via GitHub
• Re: [PR] Update BOM to 26.71.0 [beam] via GitHub
• [I] [Bug]: PostCommit YAML Xlang Direct is flaky [beam] via GitHub
  • Re: [I] [Bug]: PostCommit YAML Xlang Direct is flaky [beam] via GitHub
• Re: [I] The PreCommit Python Coverage job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python Coverage job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python Coverage job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python Coverage job is flaky [beam] via GitHub
• [I] [Feature Request]: Ability to override the endpoint for Google Cloud Storage [beam] via GitHub
  • Re: [I] [Feature Request]: Ability to override the endpoint for Google Cloud Storage [beam] via GitHub
  • Re: [I] [Feature Request]: Ability to override the endpoint for Google Cloud Storage [beam] via GitHub
• Re: [I] [Feature Request]:[Go SDK] Improve "bad return type" messaging [beam] via GitHub
  • Re: [I] [Feature Request]:[Go SDK] Improve "bad return type" messaging [beam] via GitHub
• Re: [I] [Feature Request]: Develop a way to evolve the construction schema used by transforms safely [beam] via GitHub
  • Re: [I] [Feature Request]: Develop a way to evolve the construction schema used by transforms safely [beam] via GitHub
• Re: [I] [CsvIO]: Finalize CsvIOReadFiles [beam] via GitHub
  • Re: [I] [CsvIO]: Finalize CsvIOReadFiles [beam] via GitHub
• Re: [I] [Feature Request]: Add OrderedListState test in StateInternalsTest [beam] via GitHub
  • Re: [I] [Feature Request]: Add OrderedListState test in StateInternalsTest [beam] via GitHub
• Re: [I] [Feature Request]: Implement equals, hashCode in FlinkRunner's OrderedListState. [beam] via GitHub
  • Re: [I] [Feature Request]: Implement equals, hashCode in FlinkRunner's OrderedListState. [beam] via GitHub
• Re: [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] via GitHub
  • Re: [I] [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub [beam] via GitHub
• Re: [I] [Task] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] via GitHub
  • Re: [I] [Task] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] via GitHub
  • Re: [I] [Task] To include `additional_bq_parameters` in StorageWriteToBigQuery() [beam] via GitHub
• Re: [PR] feat: Qdrant Search Handler [beam] via GitHub
  • Re: [PR] feat: Qdrant Search Handler [beam] via GitHub
• Re: [PR] Add artifactregistry.writer role to beam-github-actions service account [beam] via GitHub
  • Re: [PR] Add artifactregistry.writer role to beam-github-actions service account [beam] via GitHub
• Re: [I] [Bug]: Type hints lost in core transforms [beam] via GitHub
• [PR] [KafkaIO] Replace end offset consumer with admin client [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with admin client [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with admin client [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with admin client [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
  • Re: [PR] [KafkaIO] Replace end offset consumer with sum of Consumer.position(TopicPartition) and Consumer.currentLag(TopicPartition) [beam] via GitHub
• [PR] Fix DinD startup failures [beam] via GitHub
  • Re: [PR] Fix DinD startup failures [beam] via GitHub
  • Re: [PR] Fix DinD startup failures [beam] via GitHub
  • Re: [PR] Fix DinD startup failures [beam] via GitHub
  • [PR] Fix DinD startup failures [beam] via GitHub
  • Re: [PR] Fix DinD startup failures [beam] via GitHub
  • Re: [PR] Fix DinD startup failures [beam] via GitHub
  • Re: [PR] Fix DinD startup failures [beam] via GitHub

• Earlier messages
• Later messages