github  

Messages by Date

• 2025/04/27 [PR] Bump github.com/golang-cz/devslog from 0.0.11 to 0.0.13 in /sdks [beam] via GitHub
• 2025/04/27 Re: [PR] Updates YAML SDK to replace Kafka read/write transforms with equivalent managed transforms [beam] via GitHub
• 2025/04/27 [I] [Feature Request]: Cap number of keys in Reshuffle.viaRandomKey [beam] via GitHub
• 2025/04/27 [PR] Updates YAML SDK to replace Kafka read/write transforms with equivalent managed transforms [beam] via GitHub
• 2025/04/27 Re: [PR] create helper function [beam] via GitHub
• 2025/04/27 [PR] Add option to create metedata filter with function. [beam] via GitHub
• 2025/04/27 Re: [PR] create helper function [beam] via GitHub
• 2025/04/27 Re: [PR] Use Java 17 for Debezium IO #34747 [beam] via GitHub
• 2025/04/27 Re: [PR] Use Java 17 for Debezium IO #34747 [beam] via GitHub
• 2025/04/27 Re: [PR] Use Java 17 for Debezium IO #34747 [beam] via GitHub
• 2025/04/27 Re: [PR] Use Java 17 for Debezium IO #34747 [beam] via GitHub
• 2025/04/27 [PR] BigQuery embeddings colab [beam] via GitHub
• 2025/04/27 Re: [PR] Bigquery embedding colab [beam] via GitHub
• 2025/04/27 [PR] Bigquery embedding colab [beam] via GitHub
• 2025/04/27 Re: [I] The PreCommit YAML Xlang Direct job is flaky [beam] via GitHub
• 2025/04/27 [I] The PreCommit YAML Xlang Direct job is flaky [beam] via GitHub
• 2025/04/27 Re: [PR] Implement a `Top` partitioner [beam] via GitHub
• 2025/04/27 Re: [PR] Use Java 17 for Debezium IO #34747 [beam] via GitHub
• 2025/04/27 [PR] Use Java 17 for Debezium IO #34747 [beam] via GitHub
• 2025/04/26 Re: [PR] 34749 reflect datum factory cache [beam] via GitHub
• 2025/04/26 Re: [PR] 34749 reflect datum factory cache [beam] via GitHub
• 2025/04/26 [PR] 34749 reflect datum factory cache [beam] via GitHub
• 2025/04/26 Re: [PR] Fix loopback [beam] via GitHub
• 2025/04/26 Re: [PR] Spark Runner : Support for Streaming side-inputs for Spark Runner [beam] via GitHub
• 2025/04/26 Re: [PR] Spark Runner : Support for Streaming side-inputs for Spark Runner [beam] via GitHub
• 2025/04/26 Re: [PR] Spark Runner : Support for Streaming side-inputs for Spark Runner [beam] via GitHub
• 2025/04/26 Re: [PR] Enable cloudpickle by default [beam] via GitHub
• 2025/04/26 Re: [I] Add documentation in Portable Runner to submit job in Java SDK [beam] via GitHub
• 2025/04/26 Re: [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] via GitHub
• 2025/04/26 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/26 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/26 Re: [PR] Add Triton Inference Server Support [beam] via GitHub
• 2025/04/26 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/26 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/25 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/25 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/25 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/25 Re: [PR] Fix SIGINT handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/25 [PR] Fix sigint handler for StopOnExitJobServer [beam] via GitHub
• 2025/04/25 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/25 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/25 [I] [Task]: Debezium IO Upgrade to 3.1.1 (and Java 17 Build Enablement) [beam] via GitHub
• 2025/04/25 Re: [PR] Remove caching for remainders of state backed iterables. [beam] via GitHub
• 2025/04/25 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/25 Re: [PR] Only declare state backed iterables on code channel. [beam] via GitHub
• 2025/04/25 Re: [PR] Only declare state backed iterables on code channel. [beam] via GitHub
• 2025/04/25 Re: [PR] Remove caching for remainders of state backed iterables. [beam] via GitHub
• 2025/04/25 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/25 Re: [PR] Enable cloudpickle by default [beam] via GitHub
• 2025/04/25 Re: [PR] Streamline non-cached state backed iterable. [beam] via GitHub
• 2025/04/25 Re: [PR] Enable cloudpickle by default [beam] via GitHub
• 2025/04/25 Re: [PR] Streamline non-cached state backed iterable. [beam] via GitHub
• 2025/04/25 Re: [PR] Streamline non-cached state backed iterable. [beam] via GitHub
• 2025/04/25 [PR] Streamline non-cached state backed iterable. [beam] via GitHub
• 2025/04/25 Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
• 2025/04/25 Re: [PR] Only declare state backed iterables on code channel. [beam] via GitHub
• 2025/04/25 Re: [PR] Add option to pickler dumps() for best-effort determinism [beam] via GitHub
• 2025/04/25 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/25 Re: [PR] Bump cloud.google.com/go/storage from 1.51.0 to 1.52.0 in /sdks [beam] via GitHub
• 2025/04/25 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/25 Re: [PR] Add Drain mode to PaneInfo [beam] via GitHub
• 2025/04/25 Re: [PR] Add Drain mode to PaneInfo [beam] via GitHub
• 2025/04/25 Re: [PR] Deep copy PipelineOptions and keep the input intact. [beam] via GitHub
• 2025/04/25 Re: [I] [Bug]: Pipeline Options changed after pipeline execution [beam] via GitHub
• 2025/04/25 Re: [PR] Add PyTorch DistilBERT Sentiment Analysis streaming pipeline for ML Benchmarks [beam] via GitHub
• 2025/04/25 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster. [beam] via GitHub
• 2025/04/25 Re: [PR] Bump cloud.google.com/go/storage from 1.51.0 to 1.52.0 in /sdks [beam] via GitHub
• 2025/04/25 Re: [PR] Bump cloud.google.com/go/spanner from 1.79.0 to 1.80.0 in /sdks [beam] via GitHub
• 2025/04/25 Re: [PR] Add PyTorch DistilBERT Sentiment Analysis streaming pipeline for ML Benchmarks [beam] via GitHub
• 2025/04/25 Re: [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] via GitHub
• 2025/04/25 Re: [I] [Bug]: Dataflow option validation fails in VSCode Jupyter notebook [beam] via GitHub
• 2025/04/25 Re: [PR] Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally [beam] via GitHub
• 2025/04/25 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/04/25 Re: [I] [BUG] | Not able to Read compressed csv file without passing any size limit [beam] via GitHub
• 2025/04/25 Re: [I] [BUG] | Not able to Read compressed csv file without passing any size limit [beam] via GitHub
• 2025/04/25 Re: [PR] Remove myself from java reviewers and focus on python and go. [beam] via GitHub
• 2025/04/25 Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] via GitHub
• 2025/04/25 Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] via GitHub
• 2025/04/25 Re: [PR] Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder [beam] via GitHub
• 2025/04/25 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/04/25 Re: [PR] Enabling long-running jobs to use federated STS assume role authentication for AWS resources. [beam] via GitHub
• 2025/04/25 Re: [PR] [Java]Add Map Type Support to JsonToRow Transformer [beam] via GitHub
• 2025/04/25 Re: [PR] Rethrowing Exception from CassandraIO's ReadFn [beam] via GitHub
• 2025/04/25 Re: [PR] Add support for top-level table properties table creation [beam] via GitHub
• 2025/04/25 Re: [PR] Bump @octokit/plugin-paginate-rest, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/25 Re: [PR] Add PyTorch DistilBERT Sentiment Analysis streaming pipeline for ML Benchmarks [beam] via GitHub
• 2025/04/25 Re: [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2025/04/25 Re: [PR] Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally [beam] via GitHub
• 2025/04/24 Re: [PR] [WIP] Flink watermark emission [beam] via GitHub
• 2025/04/24 Re: [PR] [WIP] Flink watermark emission [beam] via GitHub
• 2025/04/24 Re: [PR] [WIP] Flink watermark emission [beam] via GitHub
• 2025/04/24 Re: [PR] Bump cloud.google.com/go/storage from 1.51.0 to 1.52.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Bump google.golang.org/api from 0.229.0 to 0.230.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [I] The pr-bot-new-prs job is flaky [beam] via GitHub
• 2025/04/24 Re: [I] The pr-bot-pr-updates job is flaky [beam] via GitHub
• 2025/04/24 Re: [I] The pr-bot-pr-updates job is flaky [beam] via GitHub
• 2025/04/24 Re: [I] The pr-bot-new-prs job is flaky [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/docker/docker from 28.0.4+incompatible to 28.1.1+incompatible in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Bump cloud.google.com/go/spanner from 1.79.0 to 1.80.0 in /sdks [beam] via GitHub
• 2025/04/24 [PR] Bump cloud.google.com/go/spanner from 1.79.0 to 1.80.0 in /sdks [beam] via GitHub
• 2025/04/24 [PR] Bump github.com/docker/docker from 28.0.4+incompatible to 28.1.1+incompatible in /sdks [beam] via GitHub
• 2025/04/24 [PR] Bump google.golang.org/api from 0.229.0 to 0.230.0 in /sdks [beam] via GitHub
• 2025/04/24 [PR] Bump cloud.google.com/go/storage from 1.51.0 to 1.52.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Add changes note about TFRecord support in beam yaml and rename integration test. [beam] via GitHub
• 2025/04/24 Re: [PR] Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: Dataflow option validation fails in VSCode Jupyter notebook [beam] via GitHub
• 2025/04/24 Re: [PR] The motivation for this change is to support caching in Apache Beam. [beam] via GitHub
• 2025/04/24 Re: [PR] Fix: Remove duplicate mutations in flushBatch to prevent Datastore commit [beam] via GitHub
• 2025/04/24 Re: [PR] Fix: Remove duplicate mutations in flushBatch to prevent Datastore commit [beam] via GitHub
• 2025/04/24 Re: [PR] Remove myself from java reviewers and focus on python and go. [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: class org.apache.logging.slf4j.SLF4JLoggerContext cannot be cast to class org.apache.logging.log4j.core.LoggerContext (org.apache.logging.slf4j.SLF4JLoggerContext and org.apache.logging.log4j.core.LoggerContext are in unnamed module of loader 'app') [beam] via GitHub
• 2025/04/24 Re: [PR] Only declare state backed iterables on code channel. [beam] via GitHub
• 2025/04/24 Re: [I] The PreCommit Python job is flaky [beam] via GitHub
• 2025/04/24 Re: [I] The PreCommit Python job is flaky [beam] via GitHub
• 2025/04/24 [PR] Remove myself from java reviewers and focus on python and go. [beam] via GitHub
• 2025/04/24 Re: [PR] Deep copy PipelineOptions and keep the input intact. [beam] via GitHub
• 2025/04/24 Re: [PR] Add option to pickler dumps() for best-effort determinism [beam] via GitHub
• 2025/04/24 Re: [PR] Deep copy PipelineOptions and keep the input intact. [beam] via GitHub
• 2025/04/24 Re: [PR] Add option to pickler dumps() for best-effort determinism [beam] via GitHub
• 2025/04/24 Re: [PR] Add option to pickler dumps() for best-effort determinism [beam] via GitHub
• 2025/04/24 [PR] Only declare state backed iterables on code channel. [beam] via GitHub
• 2025/04/24 Re: [PR] Fix IndexOutOfBoundsException invoking expansion service [beam] via GitHub
• 2025/04/24 Re: [PR] Update contributor doc reflecting #33954 [beam] via GitHub
• 2025/04/24 [I] The PreCommit Python job is flaky [beam] via GitHub
• 2025/04/24 Re: [I] The PreCommit Python Coverage job is flaky [beam] via GitHub
• 2025/04/24 [PR] [Do not merge] Parse struct returned from Dataflow API to BoundedTrieData [beam] via GitHub
• 2025/04/24 Re: [PR] [WIP] Upgrade io.debezium using #33526 as a blueprint [beam] via GitHub
• 2025/04/24 Re: [PR] Skip this failed test until further investigation is done. [beam] via GitHub
• 2025/04/24 Re: [PR] Skip this failed test until further investigation is done. [beam] via GitHub
• 2025/04/24 Re: [PR] [KafkaIO] Fix concurrent consumer bug in KafkaIOIT [beam] via GitHub
• 2025/04/24 Re: [PR] Deep copy PipelineOptions and keep the input intact. [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/go-jose/go-jose/v4 from 4.0.4 to 4.0.5 in /sdks [beam] via GitHub
• 2025/04/24 [PR] Skip this failed test until further investigation is done. [beam] via GitHub
• 2025/04/24 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/04/24 [I] [Failing Test]: TestGCSIORetry.test_retry_on_throttling failed due to unknown reasons [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/go-jose/go-jose/v4 from 4.0.4 to 4.0.5 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] [ManagedIO] Single source of truth for ManagedIO configs [beam] via GitHub
• 2025/04/24 Re: [I] [Feature Request]: Include job name in GCS custom audit info [beam] via GitHub
• 2025/04/24 Re: [PR] Update RunInference type hints to PEP 585 standards [beam] via GitHub
• 2025/04/24 Re: [PR] Support customizing how built-in types are pickled for cloudpickle [beam] via GitHub
• 2025/04/24 Re: [PR] Support customizing how built-in types are pickled for cloudpickle [beam] via GitHub
• 2025/04/24 Re: [PR] Support customizing how built-in types are pickled for cloudpickle [beam] via GitHub
• 2025/04/24 Re: [PR] Update RunInference type hints to PEP 585 standards [beam] via GitHub
• 2025/04/24 Re: [PR] Fix handling of collections.Counter types [beam] via GitHub
• 2025/04/24 Re: [PR] Fix handling of collections.Counter types [beam] via GitHub
• 2025/04/24 Re: [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2025/04/24 [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2025/04/24 Re: [PR] Fix IndexOutOfBoundsException invoking expansion service [beam] via GitHub
• 2025/04/24 Re: [PR] Update contributor doc reflecting #33954 [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: gprcio limitation to < 1.66 in Python is problematic [beam] via GitHub
• 2025/04/24 Re: [PR] [DO NOT MERGE] Removed < 1.66 for grpcio [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] via GitHub
• 2025/04/24 [PR] Bump github.com/go-jose/go-jose/v4 from 4.0.4 to 4.0.5 in /sdks [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: KafkaIO unbounded read requires kafka connection on pipeline submission time [beam] via GitHub
• 2025/04/24 Re: [PR] complete implementation of open ai text embedding with test #new [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/nats-io/nats.go from 1.41.0 to 1.41.2 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Update RunInference type hints to PEP 585 standards [beam] via GitHub
• 2025/04/24 Re: [PR] Bump google.golang.org/grpc from 1.71.1 to 1.72.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Update RunInference type hints to PEP 585 standards [beam] via GitHub
• 2025/04/24 Re: [PR] Spark Runner : Support for Streaming side-inputs for Spark Runner [beam] via GitHub
• 2025/04/24 Re: [PR] Add option to pickler dumps() for best-effort determinism [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.67 to 1.17.73 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Update code-change-guide.md [beam] via GitHub
• 2025/04/24 Re: [PR] Fix Iceberg Integration tests [beam] via GitHub
• 2025/04/24 Re: [I] The IcebergIO Integration Tests job is flaky [beam] via GitHub
• 2025/04/24 Re: [PR] Fix Iceberg Integration tests [beam] via GitHub
• 2025/04/24 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster. [beam] via GitHub
• 2025/04/24 [PR] [WIP] Flink watermark emission [beam] via GitHub
• 2025/04/24 Re: [PR] [KafkaIO] Improve caching in backlog estimation and processing [beam] via GitHub
• 2025/04/24 Re: [PR] [KafkaIO] Update tracker and watermark for non-visible progress [beam] via GitHub
• 2025/04/24 [PR] [WIP] Upgrade io.debezium using #33526 as a blueprint [beam] via GitHub
• 2025/04/24 Re: [PR] Bump cloud.google.com/go/bigtable from 1.36.0 to 1.37.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.67 to 1.17.73 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Fix Iceberg Integration tests [beam] via GitHub
• 2025/04/24 Re: [PR] Fix Iceberg Integration tests [beam] via GitHub
• 2025/04/24 Re: [PR] Fix Iceberg Integration tests [beam] via GitHub
• 2025/04/24 Re: [PR] Update gcp bom to 26.50.0 [beam] via GitHub
• 2025/04/24 Re: [PR] [WIP] Upgrade version of io.debezium [beam] via GitHub
• 2025/04/24 Re: [PR] Attempt prism for pipelines with unbounded PCollections. [beam] via GitHub
• 2025/04/24 Re: [PR] Bump google.golang.org/grpc from 1.71.1 to 1.72.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] [ManagedIO] Single source of truth for ManagedIO configs [beam] via GitHub
• 2025/04/24 Re: [PR] Deep copy PipelineOptions and keep the input intact. [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/golang-cz/devslog from 0.0.11 to 0.0.12 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Bump github.com/nats-io/nats.go from 1.41.0 to 1.41.2 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Bump cloud.google.com/go/bigtable from 1.36.0 to 1.37.0 in /sdks [beam] via GitHub
• 2025/04/24 Re: [PR] Revert "Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot" [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: [Python SDK] Beam.FlatMap doesn't correctly parse TypeVar typehints [beam] via GitHub
• 2025/04/24 Re: [I] [Bug]: The python Flatten example shows an empty line 31 and nothing else [beam] via GitHub
• 2025/04/24 [I] [Bug]: [Python SDK] Beam.FlatMap doesn't correctly parse TypeVar typehints [beam] via GitHub
• 2025/04/24 Re: [I] The pr-bot-pr-updates job is flaky [beam] via GitHub
• 2025/04/24 Re: [PR] Revert "Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot" [beam] via GitHub
• 2025/04/24 Re: [PR] [KafkaIO] Update tracker and watermark for non-visible progress [beam] via GitHub
• 2025/04/24 [I] The pr-bot-pr-updates job is flaky [beam] via GitHub
• 2025/04/24 Re: [PR] Fix Iceberg Integration tests [beam] via GitHub
• 2025/04/24 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/04/24 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/04/24 Re: [PR] feat:large-row-skip-in-bigtable | added experimental options to skip … [beam] via GitHub
• 2025/04/23 Re: [PR] [extensions-proto] Return correct TypeDescriptor for ProtoCoder (#34561) [beam] via GitHub
• 2025/04/23 Re: [I] [Bug]: ProtoCoder does not return correctly encoded TypeDescriptor [beam] via GitHub

• Earlier messages
• Later messages