github  

Messages by Thread

• Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
  • Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
  • Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
  • Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
  • Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
  • Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
  • Re: [PR] Enable validates runner tests for advanced state types for Dataflow. [beam] via GitHub
• Re: [PR] Enable MapState, SetState, MultimapState validates runner tests for Dataflow. [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
  • Re: [PR] Fix DinD startup failures [beam] via GitHub
• [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [PR] Add table information to BigQueryStorageApiInsertError [beam] via GitHub
• [I] [Feature Request]: Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [I] [Feature Request]: Add table information to BigQueryStorageApiInsertError [beam] via GitHub
  • Re: [I] [Feature Request]: Add table information to BigQueryStorageApiInsertError [beam] via GitHub
• [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
  • Re: [PR] Improve coder byte calculation methods [beam] via GitHub
• [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] via GitHub
  • Re: [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] via GitHub
  • Re: [I] The go_modules in /sdks - Update #941920271 job is flaky [beam] via GitHub
• [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec [beam] via GitHub
• Re: [I] [Feature Request]: AWS SNS? [beam] via GitHub
  • Re: [I] [Feature Request]: AWS SNS? [beam] via GitHub
• Re: [I] [Feature Request]: AWS SQS [beam] via GitHub
  • Re: [I] [Feature Request]: AWS SQS [beam] via GitHub
• Re: [I] Outdated version of apache-beam on npm registry [beam] via GitHub
  • Re: [I] Outdated version of apache-beam on npm registry [beam] via GitHub
• Re: [I] [Feature Request]: Azure Event Hub [beam] via GitHub
  • Re: [I] [Feature Request]: Azure Event Hub [beam] via GitHub
• Re: [I] [Task]: Sliding window ptransform for time series data [beam] via GitHub
  • Re: [I] [Task]: Sliding window ptransform for time series data [beam] via GitHub
  • Re: [I] [Task]: Sliding window ptransform for time series data [beam] via GitHub
• [PR] Update REVIEWERS.yml [beam] via GitHub
  • Re: [PR] Update REVIEWERS.yml [beam] via GitHub
  • Re: [PR] Update REVIEWERS.yml [beam] via GitHub
  • Re: [PR] Update REVIEWERS.yml [beam] via GitHub
• Re: [I] [Feature Request]: Add support in BQ IO to emit dataset they are accessing for lineage tracking [beam] via GitHub
  • Re: [I] [Feature Request]: Add support in BQ IO to emit dataset they are accessing for lineage tracking [beam] via GitHub
• Re: [I] [Bug]: PreparePubsubWriteDoFn does not guarantee that a message will not exceed hard request limits [beam] via GitHub
  • Re: [I] [Bug]: PreparePubsubWriteDoFn does not guarantee that a message will not exceed hard request limits [beam] via GitHub
• Re: [PR] [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness [beam] via GitHub
• Re: [I] [Task]: Validate playground snippets in website documentation [beam] via GitHub
  • Re: [I] [Task]: Validate playground snippets in website documentation [beam] via GitHub
• Re: [I] [Feature Request]: Support StringSet Metrics in Beam for Dataflow [beam] via GitHub
  • Re: [I] [Feature Request]: Support StringSet Metrics in Beam for Dataflow [beam] via GitHub
• Re: [I] [Feature Request]: Implement a GroupIntoBatches(.WithShardedKey) based sink for PubsubIO.Write [beam] via GitHub
  • Re: [I] [Feature Request]: Implement a GroupIntoBatches(.WithShardedKey) based sink for PubsubIO.Write [beam] via GitHub
• Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] via GitHub
  • Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] via GitHub
  • Re: [PR] [BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness [beam] via GitHub
• Re: [PR] make use of generic type info in *Utils classes [beam] via GitHub
  • Re: [PR] make use of generic type info in *Utils classes [beam] via GitHub
• [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
  • [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• [PR] Update Python container tag [beam] via GitHub
  • Re: [PR] Update Python container tag [beam] via GitHub
  • Re: [PR] Update Python container tag [beam] via GitHub
  • Re: [PR] Update Python container tag [beam] via GitHub
• [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
  • Re: [PR] Provide more contextual error message for PyCoder [beam] via GitHub
• [I] [Feature Request]: Provide more contextual error message in VarIntCoderImpl [beam] via GitHub
  • Re: [I] [Feature Request]: Provide more contextual error message in VarIntCoderImpl [beam] via GitHub
  • Re: [I] [Feature Request]: Provide more contextual error message in VarIntCoderImpl [beam] via GitHub
• [PR] Improve error message for decoding input stream [beam] via GitHub
  • Re: [PR] Improve error message for decoding input stream [beam] via GitHub
  • Re: [PR] Improve error message for decoding input stream [beam] via GitHub
  • Re: [PR] Improve error message for decoding input stream [beam] via GitHub
  • Re: [PR] Improve error message for decoding input stream [beam] via GitHub
• Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit YAML Xlang Direct job is flaky [beam] via GitHub
• [PR] DO NOT MERGE: removing timestamp validation in FnApiDoFnRunner [beam] via GitHub
  • Re: [PR] DO NOT MERGE: removing timestamp validation in FnApiDoFnRunner [beam] via GitHub
  • Re: [PR] DO NOT MERGE: removing timestamp validation in FnApiDoFnRunner [beam] via GitHub
• Re: [PR] Only update watermark if the new value is larger than the existing value [beam] via GitHub
• Re: [I] [Bug]: BigQueryIO write inconsistent implicit int->long conversion for nullable long and for different write methods [beam] via GitHub
  • Re: [I] [Bug]: BigQueryIO write inconsistent implicit int->long conversion for nullable long and for different write methods [beam] via GitHub
  • Re: [I] [Bug]: BigQueryIO write inconsistent implicit int->long conversion for nullable long and for different write methods [beam] via GitHub
  • Re: [I] [Bug]: BigQueryIO write inconsistent implicit int->long conversion for nullable long and for different write methods [beam] via GitHub
  • Re: [I] [Bug]: BigQueryIO write inconsistent implicit int->long conversion for nullable long and for different write methods [beam] via GitHub
• Re: [PR] Adds proto fields for overwriting fetch/write state functionality [beam] via GitHub
  • Re: [PR] Adds proto fields for overwriting fetch/write state functionality [beam] via GitHub
  • Re: [PR] Adds proto fields for overwriting fetch/write state functionality [beam] via GitHub
  • Re: [PR] Adds proto fields for overwriting fetch/write state functionality [beam] via GitHub
  • Re: [PR] Adds proto fields for overwriting fetch/write state functionality [beam] via GitHub
  • Re: [PR] Adds proto fields for overwriting fetch/write state functionality [beam] via GitHub
• Re: [PR] Bump google.golang.org/api from 0.255.0 to 0.256.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.255.0 to 0.256.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.255.0 to 0.256.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.255.0 to 0.256.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.255.0 to 0.256.0 in /sdks [beam] via GitHub
• Re: [PR] Bump golang.org/x/sync from 0.17.0 to 0.18.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/sync from 0.17.0 to 0.18.0 in /sdks [beam] via GitHub
• Re: [PR] Ensure that Operations are aborted when MapTaskExecutor is closed. Add tests around setup/teardown of DoFns [beam] via GitHub
  • Re: [PR] Ensure that Operations are aborted when MapTaskExecutor is closed. Add tests around setup/teardown of DoFns [beam] via GitHub
• Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
  • Re: [PR] Introduce OutputBuilder in Java SDK [beam] via GitHub
• [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump js-yaml from 4.1.0 to 4.1.1 in /sdks/typescript [beam] via GitHub
• [PR] Initial wip commit of reimplmementing the async_dofn.py for use in Java [beam] via GitHub
• [PR] [draft] Key into partition [beam] via GitHub
  • Re: [PR] [draft] Key into partition [beam] via GitHub
  • Re: [PR] [draft] Key into partition [beam] via GitHub
  • Re: [PR] [do not merge/draft] Key into partition [beam] via GitHub
  • Re: [PR] [do not merge/draft] Key into partition [beam] via GitHub
  • Re: [PR] [do not merge/draft] Key into partition [beam] via GitHub
• Re: [I] [Bug]: [Dataflow] Don't suppress OutOfMemoryError or other Errors. [beam] via GitHub
  • Re: [I] [Bug]: [Dataflow] Don't suppress OutOfMemoryError or other Errors. [beam] via GitHub
  • Re: [I] [Bug]: [Dataflow] Don't suppress OutOfMemoryError or other Errors. [beam] via GitHub
• Re: [I] [Bug]: FirestoreIO read and write do not allow specifying the project or database id per transform. [beam] via GitHub
  • Re: [I] [Bug]: FirestoreIO read and write do not allow specifying the project or database id per transform. [beam] via GitHub
• Re: [I] [Tracker]: Clean up spotbug suppressions after upgrading to SpotBugs 4.8 [beam] via GitHub
• Re: [I] [Bug]: WriteToFiles using a custom sink with compression type .bz2 flush errors. [beam] via GitHub
  • Re: [I] [Bug]: WriteToFiles using a custom sink with compression type .bz2 flush errors. [beam] via GitHub
• Re: [I] [Feature Request]: Tour of Beam should use the beam.LogElements transform instead of defining `class Output(beam.PTransform):` [beam] via GitHub
  • Re: [I] [Feature Request]: Tour of Beam should use the beam.LogElements transform instead of defining `class Output(beam.PTransform):` [beam] via GitHub
• Re: [I] [Failing Test]: Many tests failing with invalid JWT signature [beam] via GitHub
  • Re: [I] [Failing Test]: Many tests failing with invalid JWT signature [beam] via GitHub

• Earlier messages
• Later messages