github  

Messages by Date

• 2025/09/20 Re: [PR] [2.67.0 postrelease] Fix CVE-2025-48734, CVE-2024-13009 (#36106) [beam] via GitHub
• 2025/09/20 Re: [PR] Add ThrottlingSignaler class to the Java SDK [beam] via GitHub
• 2025/09/20 Re: [I] [Feature Request]: Add keyed data to `KafkaReadSchemaTransformProvider` [beam] via GitHub
• 2025/09/20 Re: [PR] Revert "Install go for python unit tests to use prism runner." [beam] via GitHub
• 2025/09/20 [PR] Revert "Install go for python unit tests to use prism runner." [beam] via GitHub
• 2025/09/20 Re: [PR] Revert "Install go for python unit tests to use prism runner." [beam] via GitHub
• 2025/09/20 Re: [PR] Install go for python unit tests to use prism runner. [beam] via GitHub
• 2025/09/20 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2025/09/20 [I] Python Unit Tests is getting much slower since 2.67.0 [beam] via GitHub
• 2025/09/20 Re: [I] Python Unit Tests is getting much slower since 2.67.0 [beam] via GitHub
• 2025/09/20 Re: [PR] Set selected library to default before checks [beam] via GitHub
• 2025/09/20 Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
• 2025/09/20 Re: [I] [prism] Metrics from runner expanded composites aren't mapped back to user terms. [beam] via GitHub
• 2025/09/20 Re: [PR] Fix Null Pointer Exception in BigQueryIO [beam] via GitHub
• 2025/09/20 Re: [PR] Install go for python unit tests to use prism runner. [beam] via GitHub
• 2025/09/20 Re: [PR] Managed Bigquery Java Read&Write Transforms [beam] via GitHub
• 2025/09/20 Re: [PR] [Prism] Support injecting triggered bundle for a batch of elements. [beam] via GitHub
• 2025/09/20 [PR] Add ThrottlingSignaler class to the Java SDK [beam] via GitHub
• 2025/09/20 Re: [PR] Cherrypick #36063: [Java] Fix expensive OneOfType precondition messages by making them lazy [beam] via GitHub
• 2025/09/20 Re: [I] [Bug]: Errors running Python command can cause Dataflow container to crash with no further details [beam] via GitHub
• 2025/09/20 Re: [PR] Make dill optional [beam] via GitHub
• 2025/09/20 Re: [PR] Make dill optional [beam] via GitHub
• 2025/09/20 Re: [PR] Bump torch from 1.13.1 to 2.8.0 in /sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline [beam] via GitHub
• 2025/09/20 Re: [I] [Failing Test]: TriggerAlways integration test failed in prism [beam] via GitHub
• 2025/09/20 Re: [I] [Bug]: Portable runner queryMetrics returns duplicate result [beam] via GitHub
• 2025/09/20 Re: [I] [Bug]: Improve the validation error when both chain and input are given for Beam YAML [beam] via GitHub
• 2025/09/20 Re: [PR] Move Vertex LLM Inference IT Test to new Endpoint [beam] via GitHub
• 2025/09/20 Re: [PR] Install go for python unit tests to use prism runner. [beam] via GitHub
• 2025/09/20 Re: [PR] Install go for python unit tests to use prism runner. [beam] via GitHub
• 2025/09/20 [PR] Install go for python unit tests to use prism runner. [beam] via GitHub
• 2025/09/20 Re: [I] [Feature Request]: Add keyed data to `KafkaReadSchemaTransformProvider` [beam] via GitHub
• 2025/09/20 Re: [I] [Bug]: Iceberg integration tests are flaky due to stuck pipelines in HiveCatalogIT and BigQueryMetastoreCatalogIT [beam] via GitHub
• 2025/09/20 Re: [I] [Feature Request]: Generate Beam YAML managed I/O config parameters from the schema [beam] via GitHub
• 2025/09/20 Re: [PR] Managed Bigquery Java Read&Write Transforms [beam] via GitHub
• 2025/09/20 Re: [PR] Update Beam website to release 2.68.0 [beam] via GitHub
• 2025/09/20 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/20 [PR] add test and potential fix for composite transforms that output dooutputtuple [beam] via GitHub
• 2025/09/19 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2025/09/19 Re: [PR] [Prism] Support injecting trigger bundle for a batch of elements. [beam] via GitHub
• 2025/09/19 [PR] Support injecting trigger bundle for a batch of elements. [beam] via GitHub
• 2025/09/19 Re: [PR] Add GroupByEncryptedKey transform [beam] via GitHub
• 2025/09/19 Re: [PR] Adds Multimap support to JAVA FnApi [beam] via GitHub
• 2025/09/19 Re: [PR] Fix PreCommit Python Examples job [beam] via GitHub
• 2025/09/19 Re: [PR] [Java] Change precondition checks to use lazy formatting [beam] via GitHub
• 2025/09/19 Re: [PR] Remove Vertex LLM Inference Integration Test [beam] via GitHub
• 2025/09/19 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: `GEOGRAPHY` datatype breaks while using StorageWrite API in Python [beam] via GitHub
• 2025/09/19 Re: [PR] Adds Multimap support to JAVA FnApi [beam] via GitHub
• 2025/09/19 [PR] Adds Multimap support to JAVA FnApi [beam] via GitHub
• 2025/09/19 Re: [PR] Fix Null Pointer Exception in BigQueryIO [beam] via GitHub
• 2025/09/19 Re: [PR] Add GroupByEncryptedKey transform [beam] via GitHub
• 2025/09/19 [PR] [WIP] Java GBEK (AI generated) [beam] via GitHub
• 2025/09/19 Re: [PR] Bump google.golang.org/api from 0.248.0 to 0.249.0 in /sdks [beam] via GitHub
• 2025/09/19 Re: [PR] FirestoreV1 - Fix output timestamp to be based on input window, not walltime. [beam] via GitHub
• 2025/09/19 Re: [PR] Revert "Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• 2025/09/19 Re: [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub
• 2025/09/19 Re: [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub
• 2025/09/19 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2025/09/19 Re: [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub
• 2025/09/19 Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• 2025/09/19 Re: [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub
• 2025/09/19 [PR] Revert "Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• 2025/09/19 Re: [PR] Revert "Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: withOutputTags (aka side output) requires ParDo to run on each output separately [beam] via GitHub
• 2025/09/19 Re: [I] The PostCommit Java Hadoop Versions job is flaky [beam] via GitHub
• 2025/09/19 Re: [PR] Infra iam enforcer service accounts [beam] via GitHub
• 2025/09/19 Re: [I] The PreCommit Python Examples job is flaky [beam] via GitHub
• 2025/09/19 Re: [I] The PostCommit Java Hadoop Versions job is flaky [beam] via GitHub
• 2025/09/19 [I] The PostCommit Java Hadoop Versions job is flaky [beam] via GitHub
• 2025/09/19 Re: [PR] Infra iam enforcer service accounts [beam] via GitHub
• 2025/09/19 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/19 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/19 Re: [PR] Infra iam enforcer service accounts [beam] via GitHub
• 2025/09/19 [PR] Infra iam enforcer service accounts [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: FirestoreIO writes fail: timer is set to max time (294247-01-09T04:00:54.775Z) [beam] via GitHub
• 2025/09/19 Re: [PR] Fix PreCommit Python Examples job [beam] via GitHub
• 2025/09/19 Re: [PR] Fix Null Pointer Exception in BigQueryIO [beam] via GitHub
• 2025/09/19 [PR] Fix Null Pointer Exception in BigQueryIO [beam] via GitHub
• 2025/09/19 Re: [PR] Update Beam Protobuf Schema (Java) [beam] via GitHub
• 2025/09/19 Re: [PR] Update Beam Protobuf Schema (Java) [beam] via GitHub
• 2025/09/19 Re: [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] via GitHub
• 2025/09/19 Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] via GitHub
• 2025/09/19 Re: [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
• 2025/09/19 Re: [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
• 2025/09/19 Re: [PR] [Java]Add Timer Cancellation Support for @OnWindowExpiration [beam] via GitHub
• 2025/09/19 [I] [Feature Request]: Add GroupByEncryptedKey transform [beam] via GitHub
• 2025/09/19 [PR] Add GroupByEncryptedKey transform [beam] via GitHub
• 2025/09/19 [PR] Fix PreCommit Python Examples job [beam] via GitHub
• 2025/09/19 Re: [PR] Fix PreCommit Python Examples job [beam] via GitHub
• 2025/09/19 Re: [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] via GitHub
• 2025/09/19 [PR] Kerberos auth python [beam] via GitHub
• 2025/09/19 [PR] [TEST ONLY] Enable unsafe trigger tests for prism [beam] via GitHub
• 2025/09/19 [I] The PerformanceTests xlang KafkaIO Python job is flaky [beam] via GitHub
• 2025/09/19 Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• 2025/09/19 Re: [PR] Add empty side_inputs tuple to MaybeReshuffle PTransform [beam] via GitHub
• 2025/09/19 Re: [I] [Feature Request]: Implement JAR caching in the Beam YAML Provider [beam] via GitHub
• 2025/09/19 Re: [PR] Bump docker/setup-qemu-action from 1 to 3 [beam] via GitHub
• 2025/09/19 Re: [I] [Failing Test]: AttributeError for MaybeReshuffle in Python SDK [beam] via GitHub
• 2025/09/19 Re: [I] [Feature Request]: Exclusive DataFrame API for Java SDK [beam] via GitHub
• 2025/09/19 Re: [I] [Feature Request]: Exclusive DataFrame API for Java SDK [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: Registering DoFns and CombineFns Seems Excessively Slow [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: withOutputTags (aka side output) requires ParDo to run on each output separately [beam] via GitHub
• 2025/09/19 Re: [PR] Allow users to pass service name for profiler for Java And Go SDK [beam] via GitHub
• 2025/09/19 Re: [PR] Add ThrottlingSignaler class to the Java SDK [beam] via GitHub
• 2025/09/19 Re: [PR] [KafkaIO] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread [beam] via GitHub
• 2025/09/19 Re: [PR] Allow parquet import to be None [beam] via GitHub
• 2025/09/19 Re: [PR] Update Beam website to release 2.68.0 [beam] via GitHub
• 2025/09/19 Re: [PR] [Java] Change precondition checks to use lazy formatting [beam] via GitHub
• 2025/09/19 Re: [PR] Fix CVE-2025-48734, CVE-2024-13009, CVE-2025-55163, CVE-2025-58056 and CVE-2025-24970 [beam] via GitHub
• 2025/09/19 [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
• 2025/09/19 Re: [PR] Correctly exclude prism when using external transforms [beam] via GitHub
• 2025/09/19 Re: [PR] Bump google-github-actions/auth from 2 to 3 [beam] via GitHub
• 2025/09/19 Re: [PR] [#34236] Add Vertex AI Multi-Modal embedding handler [beam] via GitHub
• 2025/09/19 Re: [PR] Fix CVE-2025-48734, CVE-2024-13009 [beam] via GitHub
• 2025/09/19 Re: [PR] Bump google.golang.org/grpc from 1.75.0 to 1.75.1 in /sdks [beam] via GitHub
• 2025/09/19 Re: [PR] Set default redistribute key limit for KafkaIO read. [beam] via GitHub
• 2025/09/19 Re: [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
• 2025/09/19 Re: [PR] [Dataflow Streaming Java] Fix possible IllegalStateException when grpc streams have deadline exceeded. [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: SpannerIO.Write does not support named schemas [beam] via GitHub
• 2025/09/19 Re: [PR] Added documentation for return vs yield usage in DoFn.process() [beam] via GitHub
• 2025/09/19 Re: [PR] [Dataflow Streaming] Reuse ByteStringOutputStream buffers to reduce GC overhead [beam] via GitHub
• 2025/09/19 Re: [PR] [Prism]Support after_processing_time trigger [beam] via GitHub
• 2025/09/19 Re: [PR] Changes multimap state keys() tests to not care about order. [beam] via GitHub
• 2025/09/19 Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
• 2025/09/19 Re: [I] The PostCommit Python Arm job is flaky [beam] via GitHub
• 2025/09/19 Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
• 2025/09/19 Re: [PR] Support managed jdbc io (MySQL) [beam] via GitHub
• 2025/09/19 Re: [PR] workflows: add `ubuntu-latest` to `beam_PreCommit_Python_ML`, `beam_PostCommit_Python`, and `beam_PreCommit_Python_Coverage` [beam] via GitHub
• 2025/09/19 Re: [I] [Bug]: PrismRunner fails to execute pipeline that DirectRunner succeeds at [beam] via GitHub
• 2025/09/19 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/18 Re: [PR] Fix CVE-2025-48734, CVE-2024-13009, CVE-2025-55163, CVE-2025-58056 and CVE-2025-24970 [beam] via GitHub
• 2025/09/18 Re: [PR] Bump cloud.google.com/go/spanner from 1.85.0 to 1.85.1 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] Add empty side_inputs tuple to MaybeReshuffle PTransform [beam] via GitHub
• 2025/09/18 Re: [PR] Bump cloud.google.com/go/spanner from 1.85.0 to 1.85.1 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] Allow parquet import to be None [beam] via GitHub
• 2025/09/18 Re: [PR] Bump google.golang.org/grpc from 1.75.0 to 1.75.1 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] Fix PreCommit Python Transforms job [beam] via GitHub
• 2025/09/18 Re: [PR] Adding time partitioning support for python storage write api [beam] via GitHub
• 2025/09/18 Re: [PR] Bump cloud.google.com/go/storage from 1.56.1 to 1.56.2 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] Bump google.golang.org/api from 0.248.0 to 0.249.0 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] Bump golang.org/x/oauth2 from 0.30.0 to 0.31.0 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] Bump docker/setup-qemu-action from 1 to 3 [beam] via GitHub
• 2025/09/18 [PR] Bump docker/setup-qemu-action from 1 to 3 [beam] via GitHub
• 2025/09/18 [PR] Bump google.golang.org/api from 0.248.0 to 0.249.0 in /sdks [beam] via GitHub
• 2025/09/18 [PR] Bump cloud.google.com/go/spanner from 1.85.0 to 1.85.1 in /sdks [beam] via GitHub
• 2025/09/18 [PR] Bump cloud.google.com/go/storage from 1.56.1 to 1.56.2 in /sdks [beam] via GitHub
• 2025/09/18 [PR] Bump golang.org/x/oauth2 from 0.30.0 to 0.31.0 in /sdks [beam] via GitHub
• 2025/09/18 [PR] Bump google.golang.org/grpc from 1.75.0 to 1.75.1 in /sdks [beam] via GitHub
• 2025/09/18 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/18 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/18 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/18 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/18 Re: [PR] Move Vertex LLM Inference IT Test to new Endpoint [beam] via GitHub
• 2025/09/18 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/18 [PR] Sort output before comparison in enrichment test [beam] via GitHub
• 2025/09/18 [PR] Move Vertex LLM Inference IT Test to new Endpoint [beam] via GitHub
• 2025/09/18 Re: [PR] Add deterministic redistribute sharding for KafkaIO read. [beam] via GitHub
• 2025/09/18 Re: [PR] Hint Suggestions for invalid pipeline options [beam] via GitHub
• 2025/09/18 Re: [PR] Remove ORC from Iceberg module [beam] via GitHub
• 2025/09/18 Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] via GitHub
• 2025/09/18 Re: [PR] Add empty side_inputs tuple to MaybeReshuffle PTransform [beam] via GitHub
• 2025/09/18 Re: [PR] Correctly override apache/beam containers for RC on Dataflow runner job submission [beam] via GitHub
• 2025/09/18 Re: [PR] Allow parquet import to be None [beam] via GitHub
• 2025/09/18 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/18 Re: [PR] Correctly override apache/beam containers for RC on Dataflow runner job submission [beam] via GitHub
• 2025/09/18 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/18 Re: [PR] Timeout execution tree creation for SDK worker ops. [beam] via GitHub
• 2025/09/18 [PR] Allow parquet import to be None [beam] via GitHub
• 2025/09/18 Re: [PR] Allow parquet import to be None [beam] via GitHub
• 2025/09/18 Re: [I] Remove windowStrategy deserialization exception handling [beam] via GitHub
• 2025/09/18 Re: [PR] Fix CVE-2025-48734, CVE-2024-13009, CVE-2025-55163, CVE-2025-58056 and CVE-2025-24970 [beam] via GitHub
• 2025/09/18 Re: [I] Support UNNEST(ARRAY[STRUCT()]) [beam] via GitHub
• 2025/09/18 Re: [PR] Make dill optional [beam] via GitHub
• 2025/09/18 Re: [PR] Bump com.gradle.common-custom-user-data-gradle-plugin from 2.2.1 to 2.4.0 [beam] via GitHub
• 2025/09/18 Re: [I] Support INT32 type [beam] via GitHub
• 2025/09/18 Re: [I] Throw error for 1/0 or floating point overflow [beam] via GitHub
• 2025/09/18 Re: [I] Make HBaseIO write return so it can be composed (e.g. used with Wait.on) [beam] via GitHub
• 2025/09/18 Re: [I] BeamRelNode with different pipeline options [beam] via GitHub
• 2025/09/18 Re: [PR] [Prism] Fix an issue on pane info being overwritten by different bundles. [beam] via GitHub
• 2025/09/18 [I] Beam Python PubSubIO Does Not Support Ordered Key Publishing [beam] via GitHub
• 2025/09/18 Re: [I] ZetaSQL: support aggregations of literal values [beam] via GitHub
• 2025/09/18 Re: [I] Artifacts that use vendored calcite 1.28.0 fail with annotation processing error in :compileJava [beam] via GitHub
• 2025/09/18 Re: [I] BeamUncollectRel UncollectDoFn NullPointerException [beam] via GitHub
• 2025/09/18 Re: [I] Beam ZetaSQL supports pure SQL user-defined aggregation functions [beam] via GitHub
• 2025/09/18 Re: [PR] Fix print statement format in symtab package [beam] via GitHub
• 2025/09/18 Re: [PR] Fix flaky GrpcDirectGetWorkStreamTest.testConsumedWorkItems_itemsSplitAcrossResponses [beam] via GitHub
• 2025/09/18 Re: [I] Support ARRAY type [beam] via GitHub
• 2025/09/18 Re: [I] Support struct type [beam] via GitHub
• 2025/09/18 Re: [I] Support STRUCT member field access operator [beam] via GitHub
• 2025/09/18 Re: [I] Stop job service when pipeline execution finishes [beam] via GitHub
• 2025/09/18 Re: [I] Improve health signal for StreamingDataflowWorker [beam] via GitHub
• 2025/09/18 Re: [I] Support TIME type in BeamJavaUdfCalcRule. [beam] via GitHub
• 2025/09/18 Re: [PR] Cleanly separate v1 worker and v2 sdk harness container image handling in DataflowRunner [beam] via GitHub
• 2025/09/18 Re: [I] Remove windowStrategy deserialization exception handling [beam] via GitHub
• 2025/09/18 Re: [I] ArrayScanToUncollectConverter Unnest does not support sub-queries [beam] via GitHub
• 2025/09/18 Re: [I] hints should be rejected [beam] via GitHub
• 2025/09/18 Re: [I] Support array member accessor [beam] via GitHub
• 2025/09/18 Re: [I] ZetaSQL OFFSET support for retrieving Array Values [beam] via GitHub
• 2025/09/18 Re: [I] CONCAT function is broken [beam] via GitHub
• 2025/09/18 Re: [I] Support COVAR_SAMP function in Beam ZetaSQL [beam] via GitHub

• Earlier messages
• Later messages