github  

Messages by Thread

• [PR] fix: update deps for Gradle 9 compat, add Gradle wrapper [beam-starter-kotlin] via GitHub
• Re: [PR] Bump beamVersion from 2.42.0 to 2.48.0 [beam-starter-kotlin] via GitHub
• Re: [PR] Bump org.jetbrains.kotlin.jvm from 1.7.20 to 1.8.22 [beam-starter-kotlin] via GitHub
• [PR] Upgrade to Avro 1.12 [beam] via GitHub
  • Re: [PR] Upgrade to Avro 1.12 [beam] via GitHub
  • Re: [PR] Upgrade to Avro 1.12 [beam] via GitHub
  • Re: [PR] Upgrade to Avro 1.12 [beam] via GitHub
• [PR] MongoDB IO write connector for Beam YAML [beam] via GitHub
• [I] The PreCommit Java IOs Direct job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Java IOs Direct job is flaky [beam] via GitHub
• [PR] [ErrorProne ] fix violation in ValueInSingleWindow [beam] via GitHub
  • Re: [PR] [ErrorProne ] fix violation in ValueInSingleWindow [beam] via GitHub
  • Re: [PR] [ErrorProne ] fix violation in ValueInSingleWindow [beam] via GitHub
  • Re: [PR] [ErrorProne ] fix violation in ValueInSingleWindow [beam] via GitHub
• Re: [I] [Failing Test]: JavaUsingPython postcommit tests are failing [beam] via GitHub
• Re: [I] [Bug]: Iceberg managed connector upgrade failed in GCP Dataflow [beam] via GitHub
• Re: [I] [Task]: validate timestamps / windowing metadata in FnApiDoFnRunner [beam] via GitHub
• Re: [I] [Task]: Enable outputting scalars instead of numpy arrays using a parameter in MLTransform [beam] via GitHub
  • Re: [I] [Task]: Enable outputting scalars instead of numpy arrays using a parameter in MLTransform [beam] via GitHub
• [PR] [Iceberg] Add autosharding to yaml [beam] via GitHub
  • Re: [PR] [Iceberg] Add autosharding to yaml [beam] via GitHub
  • Re: [PR] [Iceberg] Add autosharding to yaml [beam] via GitHub
  • Re: [PR] [Iceberg] Add autosharding to yaml [beam] via GitHub
  • Re: [PR] [Iceberg] Add autosharding to yaml [beam] via GitHub
  • Re: [PR] [Iceberg] Add autosharding to yaml [beam] via GitHub
• Re: [PR] Fix flaky FileIOTest.testMatchWatchForNewFiles test under CI filesystems [beam] via GitHub
  • Re: [PR] Fix flaky FileIOTest.testMatchWatchForNewFiles test under CI filesystems [beam] via GitHub
  • Re: [PR] Fix flaky FileIOTest.testMatchWatchForNewFiles test under CI filesystems [beam] via GitHub
• [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
  • Re: [PR] BatchElements transform for Java SDK [beam] via GitHub
• [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Python SDK [beam] via GitHub
• [PR] yaml_transform_test - add some debug logs and increase row count [beam] via GitHub
  • Re: [PR] yaml_transform_test - add some debug logs and increase row count [beam] via GitHub
  • Re: [PR] yaml_transform_test - add some debug logs and increase row count [beam] via GitHub
  • Re: [PR] yaml_transform_test - add some debug logs and increase row count [beam] via GitHub
  • Re: [PR] yaml_transform_test - add some debug logs and increase row count [beam] via GitHub
• Re: [I] Beam Connector for Reading Data from Delta Lake [beam] via GitHub
• Re: [I] [Bug]: Building wheels failing on self hosted actions, working on github's runners [beam] via GitHub
• Re: [I] [Feature Request]: Make Reshuffle transform available to Beam YAML [beam] via GitHub
• Re: [I] [Feature Request]: Request to use BASIC enum when calling tables.get() in BigQuery [beam] via GitHub
• Re: [PR] Fix ProtoCoder NoSuchMethodException [beam] via GitHub
• Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
• Re: [I] [Bug]: typescript SDK - DirectRunner - readFromPubSub does not work [beam] via GitHub
  • Re: [I] [Bug]: typescript SDK - DirectRunner - readFromPubSub does not work [beam] via GitHub
• Re: [I] [Bug]: ElasticsearchIO should use RetryPolicy in case of connectivity issues [beam] via GitHub
  • Re: [I] [Bug]: ElasticsearchIO should use RetryPolicy in case of connectivity issues [beam] via GitHub
• Re: [I] [Bug]: Fix ParquetIO.Read/Parse(Files) where ParquetFileReader has row groups of zero rows [beam] via GitHub
  • Re: [I] [Bug]: Fix ParquetIO.Read/Parse(Files) where ParquetFileReader has row groups of zero rows [beam] via GitHub
• Re: [I] [Feature Request]: Modify ParquetIO.Read/Parse(Files) to use additional outputs pattern with a deadletter PCollection [beam] via GitHub
  • Re: [I] [Feature Request]: Modify ParquetIO.Read/Parse(Files) to use additional outputs pattern with a deadletter PCollection [beam] via GitHub
• Re: [I] [Feature Request]: BQ: Allow map values to be nullable in GCP SDK BigQueryIO [beam] via GitHub
• Re: [PR] [3/3] sdks/python: sink data with Milvus Search I/O connector [beam] via GitHub
• [PR] Run workflows on ubuntu-24.04 [beam] via GitHub
  • Re: [PR] Run workflows on ubuntu-24.04 [beam] via GitHub
  • Re: [PR] Run workflows on ubuntu-24.04 [beam] via GitHub
  • Re: [PR] Run workflows on ubuntu-24.04 [beam] via GitHub
• Re: [I] [Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0 [beam] via GitHub
  • Re: [I] [Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0 [beam] via GitHub
• Re: [I] DoFn.process should raise exception if something other than a List is returned [beam] via GitHub
• Re: [I] Add Kafka Streams runner [beam] via GitHub
• Re: [I] [Feature Request]: Expose pvalue.Row in core.py rather than pvalue.py [beam] via GitHub
  • Re: [I] [Feature Request]: Expose pvalue.Row in core.py rather than pvalue.py [beam] via GitHub
• Re: [I] [Failing Test]: Dataflow V2 VR Streaming Flakiness due to timeout close worker pool [beam] via GitHub
• Re: [I] [Bug]: Go pipline on Dataflow throws "java.lang.NoClassDefFoundError: org/apache/beam/vendor/grpc/v1p54p0/io/grpc/Channel" [beam] via GitHub
  • Re: [I] [Bug]: Go pipline on Dataflow throws "java.lang.NoClassDefFoundError: org/apache/beam/vendor/grpc/v1p54p0/io/grpc/Channel" [beam] via GitHub
• Re: [I] [Bug]: Unable to use @FieldAccess in DoFn for fetching Nullable Schema Fields [beam] via GitHub
  • Re: [I] [Bug]: Unable to use @FieldAccess in DoFn for fetching Nullable Schema Fields [beam] via GitHub
• Re: [I] [Failing Test]: A few failed tests for TestStream with keyed elements [beam] via GitHub
• [PR] testing poc [beam] via GitHub
  • Re: [PR] testing poc [beam] via GitHub
  • Re: [PR] testing poc [beam] via GitHub
  • Re: [PR] testing poc [beam] via GitHub
  • Re: [PR] testing poc [beam] via GitHub
  • Re: [PR] testing poc [beam] via GitHub
• [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input fixes [beam] via GitHub
  • Re: [PR] Side Input improvements [beam] via GitHub
  • Re: [PR] Side Input improvements [beam] via GitHub
  • Re: [PR] Side Input improvements [beam] via GitHub
  • Re: [PR] Side Input improvements [beam] via GitHub
• [I] The PostCommit Go job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Go job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Go job is flaky [beam] via GitHub
• [I] The PostCommit Go Dataflow ARM job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Go Dataflow ARM job is flaky [beam] via GitHub
• [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
  • Re: [PR] add datadog io normalization and yaml [beam] via GitHub
• Re: [I] [Failing Test]: GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer stuck [beam] via GitHub
  • Re: [I] [Failing Test]: GrpcLoggingServiceTest.testMultipleClientsFailingIsHandledGracefullyByServer stuck [beam] via GitHub
• Re: [I] [Bug]: BigQueryIO Write does not work using Storage_write_api on DataflowRunner with unbounded data and autosharding [beam] via GitHub
  • Re: [I] [Bug]: BigQueryIO Write does not work using Storage_write_api on DataflowRunner with unbounded data and autosharding [beam] via GitHub
• Re: [I] [Feature Request]: Support draining Spanner Change Stream connectors [beam] via GitHub
  • Re: [I] [Feature Request]: Support draining Spanner Change Stream connectors [beam] via GitHub
• Re: [I] [prism] Processing Time handling (TestStream, Timers, ProcessContinuations) [beam] via GitHub
  • Re: [I] [prism] Processing Time handling (TestStream, Timers, ProcessContinuations) [beam] via GitHub
• Re: [PR] Update go version. [beam] via GitHub
• Re: [I] [Task]: Deprecate Java8 [beam] via GitHub
• [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
• [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
• [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
  • Re: [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
  • Re: [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
  • Re: [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
• [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
• [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
• Re: [I] [Bug]: Unhandled exception in KafkaIO SDF [beam] via GitHub
• Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• Re: [PR] fix: correct typo "occured" to "occurred" in data_sampler.py [beam] via GitHub
• Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] via GitHub
• Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
  • Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
  • Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
• Re: [PR] Omit state commits in stateful Dofn [beam] via GitHub
• Re: [PR] Add Python example for slowly updating global window side input pattern [beam] via GitHub
  • Re: [PR] Add Python example for slowly updating global window side input pattern [beam] via GitHub
• Re: [PR] [python][io] Add native GenerateSequence bounded PTransform (#18088) [beam] via GitHub
  • Re: [PR] [python][io] Add native GenerateSequence bounded PTransform (#18088) [beam] via GitHub
• Re: [PR] [Go SDK] Rewrite dot runner to generate DOT from portable pipeline proto [beam] via GitHub
• Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior [beam] via GitHub
  • Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior [beam] via GitHub
• Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] via GitHub
• Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] via GitHub
  • Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] via GitHub
• Re: [PR] Bump cloud.google.com/go/bigquery from 1.72.0 to 1.73.1 in /sdks [beam] via GitHub
• Re: [PR] Bump google.golang.org/api from 0.257.0 to 0.269.0 in /sdks [beam] via GitHub
• [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub

• Earlier messages