github  

Messages by Date

• 2024/12/24 Re: [PR] The motivation for this change is to support caching in Apache Beam. [beam] via GitHub
• 2024/12/23 Re: [PR] Suppress DataFrame.applymap deprecation warning [beam] via GitHub
• 2024/12/23 Re: [PR] Bump net.researchgate.release from 2.8.1 to 3.1.0 [beam] via GitHub
• 2024/12/23 [PR] Suppress DataFrame.applymap deprecation warning [beam] via GitHub
• 2024/12/23 [PR] Bump net.researchgate.release from 2.8.1 to 3.1.0 [beam] via GitHub
• 2024/12/23 Re: [PR] Bump jinja2 from 3.1.4 to 3.1.5 in /sdks/python/container/py310 [beam] via GitHub
• 2024/12/23 Re: [PR] Bump jinja2 from 3.1.4 to 3.1.5 in /sdks/python/container/py310 [beam] via GitHub
• 2024/12/23 Re: [PR] Bump jinja2 from 3.1.4 to 3.1.5 in /sdks/python/container/py310 [beam] via GitHub
• 2024/12/23 [PR] Bump jinja2 from 3.1.4 to 3.1.5 in /sdks/python/container/py310 [beam] via GitHub
• 2024/12/23 Re: [PR] [Prism] Use the worker-id gRPC metadata [beam] via GitHub
• 2024/12/23 Re: [PR] Introduce a BoundedTrie metric which is used to efficiently store and… [beam] via GitHub
• 2024/12/23 Re: [PR] [Managed Iceberg] refactor integration tests; make it easy to add a new catalog to test suite [beam] via GitHub
• 2024/12/23 [PR] [Managed Iceberg] refactor integration tests; make it easy to add a new catalog to test suite [beam] via GitHub
• 2024/12/23 Re: [I] [Bug]: beam_CleanupGCPResources is failing with log "The operation was canceled" [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] propogate error_handling to windowing composite config [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] propogate error_handling to windowing composite config [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] propogate error_handling to windowing composite config [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] propogate error_handling to windowing composite config [beam] via GitHub
• 2024/12/23 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] propogate error_handling to windowing composite config [beam] via GitHub
• 2024/12/23 [PR] [yaml] propogate error_handling to windowing composite config [beam] via GitHub
• 2024/12/23 Re: [PR] Add rag enrichment and ingestion. [beam] via GitHub
• 2024/12/23 Re: [PR] Add rag enrichment and ingestion. [beam] via GitHub
• 2024/12/23 Re: [I] [Bug]: Support error handling in PyTransform [beam] via GitHub
• 2024/12/23 Re: [PR] Clean up Python Tests workflow [beam] via GitHub
• 2024/12/23 Re: [PR] Clean up Python Tests workflow [beam] via GitHub
• 2024/12/23 [I] [Bug]: JDBC javasdk_date:v1 decode error [beam] via GitHub
• 2024/12/23 [I] [Task]: Use DataFrame.map instead of DataFrame.applymap [beam] via GitHub
• 2024/12/23 Re: [I] Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime [beam] via GitHub
• 2024/12/23 Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime [beam] via GitHub
• 2024/12/23 Re: [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] via GitHub
• 2024/12/23 Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• 2024/12/23 Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] add mysql, oracle, postgres and sql server providers [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] Add yaml_provider.py Unit Tests [beam] via GitHub
• 2024/12/23 Re: [PR] [yaml] Add yaml_provider.py Unit Tests [beam] via GitHub
• 2024/12/23 Re: [PR] Fix Maybereshuffle [beam] via GitHub
• 2024/12/23 Re: [PR] Fix Maybereshuffle [beam] via GitHub
• 2024/12/23 Re: [PR] Parameterize GoogleCloudStorage provider in GcsUtil to unblock gcs-co… [beam] via GitHub
• 2024/12/23 Re: [PR] Add histogram to metrics container [beam] via GitHub
• 2024/12/22 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.28.6 to 1.28.7 in /sdks [beam] via GitHub
• 2024/12/22 Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.6 to 1.32.7 in /sdks [beam] via GitHub
• 2024/12/22 [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.28.6 to 1.28.7 in /sdks [beam] via GitHub
• 2024/12/22 [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.32.6 to 1.32.7 in /sdks [beam] via GitHub
• 2024/12/22 [PR] [Prism] Use the worker-id gRPC metadata [beam] via GitHub
• 2024/12/22 Re: [PR] Adding Google Storage Requester pays feature to Golang SDK. [beam] via GitHub
• 2024/12/22 Re: [PR] Parameterize GoogleCloudStorage provider in GcsUtil to unblock gcs-co… [beam] via GitHub
• 2024/12/22 Re: [I] [Bug]: symbols are not exported from `apache_beam`, causing type errors from Pylance [beam] via GitHub
• 2024/12/22 [I] [Bug]: symbols are not exported from `apache_beam`, causing type errors from Pylance [beam] via GitHub
• 2024/12/22 Re: [PR] Add support for Flink 1.20 [beam] via GitHub
• 2024/12/21 Re: [PR] Implement "stage_file_with_retry" for robust file staging [beam] via GitHub
• 2024/12/21 Re: [PR] SolaceIO: separate auth and session settings [beam] via GitHub
• 2024/12/21 Re: [I] [Bug]: Add check for self-referencing input in YAML transform [beam] via GitHub
• 2024/12/21 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/21 Re: [PR] Update transforms module to PEP 585 type hints [beam] via GitHub
• 2024/12/21 Re: [PR] Adds references to KeyCommitTooLargeException docs [beam] via GitHub
• 2024/12/20 Re: [PR] Implement "stage_file_with_retry" for robust file staging [beam] via GitHub
• 2024/12/20 Re: [PR] Implement "stage_file_with_retry" for robust file staging [beam] via GitHub
• 2024/12/20 [PR] Implement "stage_file_with_retry" for robust file staging [beam] via GitHub
• 2024/12/20 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/20 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf message base class [beam] via GitHub
• 2024/12/20 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/20 Re: [I] [Bug]: beam_CleanupGCPResources is failing with log "The operation was canceled" [beam] via GitHub
• 2024/12/20 [I] [Bug]: beam_CleanupGCPResources is failing due to "The operation was canceled" [beam] via GitHub
• 2024/12/20 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/20 Re: [PR] Migrate Beam Go to use the new Opaque Protocol Buffers [beam] via GitHub
• 2024/12/20 Re: [I] [Bug]: Metrics not showing up in the FlinkRunner [beam] via GitHub
• 2024/12/20 [PR] Migrate Beam Go to use the new Opaque Protocol Buffers [beam] via GitHub
• 2024/12/20 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/20 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/20 Re: [PR] Update golang.org/x/net to 0.33.0 to avoid a CVE. [beam] via GitHub
• 2024/12/20 Re: [PR] Read worker harness image name from pipeline option for portable runners [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add better error message for python MapToFields expression [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf Message base class [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add FileIO docs [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add FileIO docs [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add FileIO docs [beam] via GitHub
• 2024/12/20 Re: [PR] Add Iceberg support for name-based mapping schema [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] allow logging bytes in LogForTesting [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] allow logging bytes in LogForTesting [beam] via GitHub
• 2024/12/20 [PR] [yaml] allow logging bytes in LogForTesting [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf Message base class [beam] via GitHub
• 2024/12/20 Re: [PR] Read worker harness image name from pipeline option for portable runners [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf Message base class [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf Message base class [beam] via GitHub
• 2024/12/20 Re: [PR] Introduce a BoundedTrie metric which is used to efficiently store and… [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf Message base class [beam] via GitHub
• 2024/12/20 Re: [PR] Use other fallback coders for protobuf Message base class [beam] via GitHub
• 2024/12/20 [PR] Use other fallback coders for protobuf Message base class. [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/20 Re: [PR] Support Iceberg partition identity transform [beam] via GitHub
• 2024/12/20 Re: [PR] Bump google.golang.org/grpc from 1.67.2 to 1.69.2 in /sdks [beam] via GitHub
• 2024/12/20 Re: [PR] Update golang.org/x/net to 0.33.0 to avoid a CVE. [beam] via GitHub
• 2024/12/20 Re: [PR] Update golang.org/x/net to 0.33.0 to avoid a CVE. [beam] via GitHub
• 2024/12/20 [PR] Update golang.org/x/net to 0.33.0 to avoid a CVE. [beam] via GitHub
• 2024/12/20 Re: [PR] Bump google.golang.org/api from 0.212.0 to 0.214.0 in /sdks [beam] via GitHub
• 2024/12/20 Re: [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 27.4.1+incompatible in /sdks [beam] via GitHub
• 2024/12/20 [I] [Task]: Remove Deprecated AWS v1 IOs [beam] via GitHub
• 2024/12/20 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/20 Re: [PR] Add rag enrichment and ingestion. [beam] via GitHub
• 2024/12/20 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/20 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/20 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/20 Re: [PR] SolaceIO: separate auth and session settings [beam] via GitHub
• 2024/12/20 Re: [PR] [docs] Add new Python SchemaTransform multi-lang guide [beam] via GitHub
• 2024/12/20 Re: [PR] Tour of Beam: update GroupByKey example [beam] via GitHub
• 2024/12/20 Re: [PR] Adding Google Storage Requester pays feature to Golang SDK. [beam] via GitHub
• 2024/12/19 Re: [PR] Bump google.golang.org/api from 0.212.0 to 0.214.0 in /sdks [beam] via GitHub
• 2024/12/19 Re: [PR] Bump google.golang.org/api from 0.212.0 to 0.213.0 in /sdks [beam] via GitHub
• 2024/12/19 [PR] Bump google.golang.org/api from 0.212.0 to 0.214.0 in /sdks [beam] via GitHub
• 2024/12/19 Re: [PR] Bump google.golang.org/api from 0.212.0 to 0.213.0 in /sdks [beam] via GitHub
• 2024/12/19 Re: [PR] disable cache for beam_Publish_Beam_SDK_Snapshots.yml when running Python [beam] via GitHub
• 2024/12/19 Re: [PR] disable cache for beam_Publish_Beam_SDK_Snapshots.yml when running Python [beam] via GitHub
• 2024/12/19 Re: [I] The Clean Up GCP Resources job is flaky [beam] via GitHub
• 2024/12/19 [I] The Clean Up GCP Resources job is flaky [beam] via GitHub
• 2024/12/19 Re: [PR] disable cache for beam_Publish_Beam_SDK_Snapshots.yml when running Python [beam] via GitHub
• 2024/12/19 [PR] disable cache for beam_Publish_Beam_SDK_Snapshots.yml when running Python [beam] via GitHub
• 2024/12/19 Re: [I] DatastoreV1.write() Should Optionally Return PCollection<Void> [beam] via GitHub
• 2024/12/19 Re: [PR] Introduce a BoundedTrie metric which is used to efficiently store and… [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/19 Re: [PR] [WIP] Update xlang kinesis to v2 [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [I] [Bug]: beam_Publish_Beam_SDK_Snapshots is extremely flaky due to failing to build wheels [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] Add rag enrichment and ingestion. [beam] via GitHub
• 2024/12/19 Re: [PR] Add rag enrichment and ingestion. [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 [PR] Update typehinting code to use primitives and collections types as main types over typing variants [beam] via GitHub
• 2024/12/19 Re: [PR] [BigQueryIO] fetch updated schema for newly created Storage API stream writers [beam] via GitHub
• 2024/12/19 Re: [PR] Revert three commits related to supporting custom coder in reshuffle [beam] via GitHub
• 2024/12/19 Re: [PR] Move Dataflow Python Managed tests to prod [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] [BigQueryIO] fetch updated schema for newly created Storage API stream writers [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed BigQuery] use file loads with Avro format for better performance [beam] via GitHub
• 2024/12/19 Re: [PR] Move Dataflow Python Managed tests to prod [beam] via GitHub
• 2024/12/19 [PR] Move Dataflow Python Managed tests to prod [beam] via GitHub
• 2024/12/19 Re: [PR] Migrate lineage counters to bounded tries. [beam] via GitHub
• 2024/12/19 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/19 Re: [PR] [yaml] add RunInference support with VertexAI [beam] via GitHub
• 2024/12/19 Re: [PR] Kafka add gauge v1 [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed BigQuery] use file loads with Avro format for better performance [beam] via GitHub
• 2024/12/19 Re: [I] [Task]: Add new Python SchemaTransform multi-language documentation [beam] via GitHub
• 2024/12/19 Re: [PR] Improve existing Python multi-lang SchemaTransform examples [beam] via GitHub
• 2024/12/19 Re: [PR] Use state sampler stub to defer metrics updates when DoFn#process is executed in subprocess. [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed BigQuery] use file loads with Avro format for better performance [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed BigQuery] use file loads with Avro format for better performance [beam] via GitHub
• 2024/12/19 [I] [Bug]: beam_Publish_Beam_SDK_Snapshots is extremely flaky due to failing to build wheels [beam] via GitHub
• 2024/12/19 Re: [I] [Bug]: Error on start-build-env.sh [beam] via GitHub
• 2024/12/19 Re: [I] [Bug]: Error on start-build-env.sh [beam] via GitHub
• 2024/12/19 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2024/12/19 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2024/12/19 Re: [PR] Add 2.63.0 section to CHANGES.md [beam] via GitHub
• 2024/12/19 Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
• 2024/12/19 Re: [I] The PostCommit XVR Spark3 job is flaky [beam] via GitHub
• 2024/12/19 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/19 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/19 Re: [I] DatastoreV1.write() Should Optionally Return PCollection<Void> [beam] via GitHub
• 2024/12/19 [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2024/12/19 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/19 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/19 [PR] Add 2.63.0 section to CHANGES.md [beam] via GitHub
• 2024/12/19 Re: [PR] Add OrderedListState support for SparkRunner [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed BigQuery] use file loads with Avro format for better performance [beam] via GitHub
• 2024/12/19 Re: [I] [Distroless] Enable Distroless Java SDK based container images [beam] via GitHub
• 2024/12/19 Re: [PR] Bump Iceberg to v1.6.1 [beam] via GitHub
• 2024/12/19 Re: [PR] Bump Iceberg to v1.6.1 [beam] via GitHub
• 2024/12/19 Re: [PR] [WIP] Add background thread and caching of consumers to Kafka SDF [beam] via GitHub
• 2024/12/19 Re: [PR] [WIP] Add background thread and caching of consumers to Kafka SDF [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed Iceberg] Use table file size property if exists [beam] via GitHub
• 2024/12/19 Re: [PR] [Managed Iceberg] Use table file size property if exists [beam] via GitHub
• 2024/12/19 Re: [PR] Add Iceberg support for name-based mapping schema [beam] via GitHub
• 2024/12/19 Re: [PR] Support Iceberg partition identity transform [beam] via GitHub
• 2024/12/19 Re: [PR] Add support for Iceberg table identifiers with special characters [beam] via GitHub
• 2024/12/19 Re: [PR] Bump Iceberg to v1.6.1 [beam] via GitHub
• 2024/12/19 Re: [PR] Add option to adjust ReadChangeStream API timeout to allow longer timeout for longer checkpoint durations [beam] via GitHub
• 2024/12/19 Re: [PR] Enable caching in Python tests workflow [beam] via GitHub
• 2024/12/19 Re: [PR] [java] BQ: Add avro schema to BQ TableSchema conversion [beam] via GitHub
• 2024/12/19 Re: [PR] [java] BQ: Add avro schema to BQ TableSchema conversion [beam] via GitHub
• 2024/12/19 Re: [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/19 Re: [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/19 Re: [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/19 Re: [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/19 Re: [I] Add integration testing for BQ Storage API write modes [beam] via GitHub
• 2024/12/19 Re: [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/19 Re: [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/19 [PR] [java] Fix avro logical-types conversions for BQ storage [beam] via GitHub
• 2024/12/18 Re: [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 27.4.1+incompatible in /sdks [beam] via GitHub
• 2024/12/18 Re: [PR] Bump google.golang.org/grpc from 1.67.2 to 1.69.2 in /sdks [beam] via GitHub
• 2024/12/18 [PR] Bump google.golang.org/grpc from 1.67.2 to 1.69.2 in /sdks [beam] via GitHub
• 2024/12/18 Re: [PR] Bump github.com/docker/docker from 27.3.1+incompatible to 27.4.0+incompatible in /sdks [beam] via GitHub

• Earlier messages
• Later messages