github  

Messages by Date

• 2025/04/05 Re: [PR] Add the ability to unit test YAML pipelines. [beam] via GitHub
• 2025/04/05 [PR] Enabling AWS STS credentials refresh for federated authentication [beam] via GitHub
• 2025/04/05 [PR] Add reducers for threading.Lock and EnumDescriptor. [beam] via GitHub
• 2025/04/05 Re: [PR] Fix PostCommit TransformService Direct job [beam] via GitHub
• 2025/04/05 [PR] Fix PostCommit Java SingleStoreIO IT job [beam] via GitHub
• 2025/04/05 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2025/04/05 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.6 to 1.29.9 in /sdks [beam] via GitHub
• 2025/04/05 Re: [PR] Update reviewers to more accurately match current state of repo [beam] via GitHub
• 2025/04/05 Re: [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work with WRITE_TRUNCATE write disposition (#34247) [beam] via GitHub
• 2025/04/05 Re: [I] [Bug]: beam.Map function outputs no data after beam.GroupByKey using DataflowRunner [beam] via GitHub
• 2025/04/05 Re: [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] via GitHub
• 2025/04/05 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] via GitHub
• 2025/04/05 Re: [I] [Feature Request]: Support Time Partitioned Test Tables in BigqueryResourceManager [beam] via GitHub
• 2025/04/05 Re: [PR] do not block other threads from health checking if a stream is blocked [beam] via GitHub
• 2025/04/05 Re: [PR] Fix CVE-2025-25193 [beam] via GitHub
• 2025/04/05 Re: [PR] Preserve pane index through reshuffle. [beam] via GitHub
• 2025/04/05 Re: [PR] Bump golang.org/x/net from 0.35.0 to 0.37.0 in /sdks [beam] via GitHub
• 2025/04/05 [PR] Updated the republished workflow to 2.64.0 [beam] via GitHub
• 2025/04/05 Re: [PR] Add native Beam schematransform autogen snippet [beam] via GitHub
• 2025/04/05 Re: [PR] Expose add-modules JVM option in SDKHarnessOptions [beam] via GitHub
• 2025/04/05 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] via GitHub
• 2025/04/05 Re: [PR] Create a varint32 coder and used it for RowCoder [beam] via GitHub
• 2025/04/05 Re: [PR] Upgrade Iceberg BQMS version [beam] via GitHub
• 2025/04/05 Re: [PR] Add native Beam schematransform autogen snippet [beam] via GitHub
• 2025/04/05 Re: [I] The PostCommit Java Jpms Dataflow Java17 job is flaky [beam] via GitHub
• 2025/04/05 Re: [PR] add generics support to AutoValueUtils helpers [beam] via GitHub
• 2025/04/05 [PR] ML benchmark pipelines [beam] via GitHub
• 2025/04/05 Re: [PR] Create a varint32 coder and used it for RowCoder [beam] via GitHub
• 2025/04/05 Re: [PR] More precise binary operation inference. [beam] via GitHub
• 2025/04/05 Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime [beam] via GitHub
• 2025/04/05 Re: [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] via GitHub
• 2025/04/05 Re: [I] The PostCommit XVR Samza job is flaky [beam] via GitHub
• 2025/04/05 Re: [PR] remove private ipv6 check [beam] via GitHub
• 2025/04/05 Re: [PR] Support Time Partitioned Test Tables in BigqueryResourceManager [beam] via GitHub
• 2025/04/05 Re: [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] via GitHub
• 2025/04/05 Re: [PR] plumb grpc flow control settings via UserWorkerRunnerV1Settings [beam] via GitHub
• 2025/04/05 Re: [PR] Handle missing tables more gracefully. [beam] via GitHub
• 2025/04/05 [PR] Update verify_release_build.sh [beam] via GitHub
• 2025/04/05 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] via GitHub
• 2025/04/05 Re: [PR] Fix link typos [beam] via GitHub
• 2025/04/05 Re: [PR] Update pypi documentation 30145 [beam] via GitHub
• 2025/04/05 Re: [PR] Bump github.com/fsouza/fake-gcs-server from 1.52.1 to 1.52.2 in /sdks [beam] via GitHub
• 2025/04/05 Re: [PR] Bump org.apache.beam:beam-runners-direct-java from 2.59.0 to 2.60.0 [beam-starter-java] via GitHub
• 2025/04/05 Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] via GitHub
• 2025/04/05 Re: [PR] Update build.gradle [beam] via GitHub
• 2025/04/05 Re: [PR] Create a varint32 coder and used it for RowCoder [beam] via GitHub
• 2025/04/05 Re: [PR] Safeguard boundedtrie result [beam] via GitHub
• 2025/04/05 Re: [PR] Add rc00 tag [beam] via GitHub
• 2025/04/05 Re: [PR] Remove social media pieces from release guide [beam] via GitHub
• 2025/04/05 Re: [I] The PreCommit Java job is flaky [beam] via GitHub
• 2025/04/05 Re: [I] [Bug]: javaJar provider does not work with --yaml_pipeline flag: TypeError: a bytes-like object is required, not 'str' [beam] via GitHub
• 2025/04/05 Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
• 2025/04/05 Re: [PR] Add STRING format to ReadFromKafka schema transform. [beam] via GitHub
• 2025/04/05 Re: [PR] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] via GitHub
• 2025/04/05 Re: [PR] Fix postcommit python flaky tests [beam] via GitHub
• 2025/04/05 Re: [PR] Bump @octokit/plugin-paginate-rest, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/05 Re: [I] [Bug]: javaJar provider does not work with --yaml_pipeline flag: TypeError: a bytes-like object is required, not 'str' [beam] via GitHub
• 2025/04/05 Re: [PR] sdks/python: enrich data with CloudSQL [beam] via GitHub
• 2025/04/05 Re: [PR] test commit [beam] via GitHub
• 2025/04/05 Re: [PR] Add Drain mode to PaneInfo [beam] via GitHub
• 2025/04/05 [PR] Remove social media pieces from release guide [beam] via GitHub
• 2025/04/05 [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] via GitHub
• 2025/04/05 [PR] Interpolate console URL properly in error case [beam] via GitHub
• 2025/04/05 [PR] Issue warnings when dataSourceConfiguration and dataSourceProviderFn are set [beam] via GitHub
• 2025/04/05 Re: [PR] Bump golang.org/x/net from 0.35.0 to 0.37.0 in /sdks [beam] via GitHub
• 2025/04/05 Re: [I] The PostCommit Java IO Performance Tests job is flaky [beam] via GitHub
• 2025/04/05 Re: [PR] Remove type coercion of `FinalizeWrite` in iobase.py [beam] via GitHub
• 2025/04/05 [PR] Update build.gradle (#34401) [beam] via GitHub
• 2025/04/05 Re: [PR] Update release-guide.md [beam] via GitHub
• 2025/04/05 Re: [PR] Introduce RemoteModelHandler abstract base class [beam] via GitHub
• 2025/04/05 Re: [PR] Introduce RemoteModelHandler abstract base class [beam] via GitHub
• 2025/04/05 Re: [PR] [Java] Add Gauge Metric Extraction to DataflowMetrics [beam] via GitHub
• 2025/04/05 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] via GitHub
• 2025/04/05 Re: [PR] [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch [beam] via GitHub
• 2025/04/05 Re: [PR] Avoid calling getStackTrace when results are cached in RowCoderGenerator.generate [beam] via GitHub
• 2025/04/05 Re: [PR] [Managed Iceberg] unbounded source [beam] via GitHub
• 2025/04/05 Re: [PR] [KafkaIO] Improve caching in backlog estimation and processing [beam] via GitHub
• 2025/04/05 [PR] [KafkaIO] Improve caching in backlog estimation and processing [beam] via GitHub
• 2025/04/05 Re: [PR] Preserve pane index through reshuffle. [beam] via GitHub
• 2025/04/05 Re: [PR] added "Run Java Mobile Gaming RC Validation" [beam] via GitHub
• 2025/04/05 Re: [PR] do not block other threads from health checking if a stream is blocked [beam] via GitHub
• 2025/04/05 Re: [PR] [Dataflow Streaming] Optimize serialization of small commits [beam] via GitHub
• 2025/04/05 Re: [PR] Support Time Partitioned Test Tables in BigqueryResourceManager [beam] via GitHub
• 2025/04/05 [PR] Label managed transform [beam] via GitHub
• 2025/04/05 Re: [PR] Bump @octokit/plugin-paginate-rest, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/05 Re: [PR] Factor out a get_default_sql_provider() function. [beam] via GitHub
• 2025/04/05 Re: [PR] [Managed Iceberg] unbounded source [beam] via GitHub
• 2025/04/05 [PR] updated the release guide [beam] via GitHub
• 2025/04/05 Re: [PR] Fix link typos [beam] via GitHub
• 2025/04/05 Re: [I] The PreCommit Java job is flaky [beam] via GitHub
• 2025/04/05 [PR] Add ability to specify partition bounds via jdbc xlang. [beam] via GitHub
• 2025/04/05 Re: [PR] [BEAM-34076] Implement TTL-based caching for BigQuery table definitions [beam] via GitHub
• 2025/04/05 Re: [PR] Fn Runner Watermark issue [beam] via GitHub
• 2025/04/05 Re: [PR] [DO NOT MERGE] Add support for collections dict subclasses [beam] via GitHub
• 2025/04/05 Re: [I] [Bug]: Security vulnerability in parquet serialization and deserialization [beam] via GitHub
• 2025/04/05 Re: [PR] [JdbcIO] add customizable validation query [beam] via GitHub
• 2025/04/05 Re: [PR] Add the simple RC workflow to validate Go SDK with wordcount [beam] via GitHub
• 2025/04/05 Re: [PR] Fix the error for directory separator [beam] via GitHub
• 2025/04/05 Re: [PR] Add the simple RC workflow to validate Go SDK with wordcount [beam] via GitHub
• 2025/04/05 Re: [PR] Add the simple RC workflow to validate Go SDK with wordcount [beam] via GitHub
• 2025/04/05 Re: [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] via GitHub
• 2025/04/05 Re: [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] via GitHub
• 2025/04/05 Re: [PR] Fix the error for directory separator [beam] via GitHub
• 2025/04/05 [I] The PreCommit Python ML tests with ML deps installed job is flaky [beam] via GitHub
• 2025/04/05 Re: [PR] Fix Docker build error by adding fallback for python3.12-distutils [beam] via GitHub
• 2025/04/05 Re: [PR] Bump @octokit/plugin-paginate-rest and @octokit/rest in /scripts/ci/issue-report [beam] via GitHub
• 2025/04/05 Re: [PR] Add ability to specify partition bounds via jdbc xlang. [beam] via GitHub
• 2025/04/05 Re: [PR] Tour of Beam: update GroupByKey example [beam] via GitHub
• 2025/04/05 Re: [PR] [AnomalyDetection] Add a notebook for anomaly detection with Z-Score [beam] via GitHub
• 2025/04/05 Re: [PR] [KafkaIO] Remove duplicate offset in range check [beam] via GitHub
• 2025/04/05 Re: [PR] Key by paneindex and reshuffle before loading files. [beam] via GitHub
• 2025/04/05 Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
• 2025/04/05 Re: [PR] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] via GitHub
• 2025/04/05 Re: [PR] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] via GitHub
• 2025/04/05 Re: [PR] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] via GitHub
• 2025/04/05 Re: [PR] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] via GitHub
• 2025/04/05 Re: [PR] Fix Republish Released Docker Images workflow [beam] via GitHub
• 2025/04/05 Re: [PR] Fix version on the master [beam] via GitHub
• 2025/04/04 Re: [PR] Bump github.com/nats-io/nats.go from 1.39.1 to 1.41.0 in /sdks [beam] via GitHub
• 2025/04/04 Re: [I] The PostCommit Java Jpms Dataflow Java17 job is flaky [beam] via GitHub
• 2025/04/04 Re: [PR] Bump github.com/nats-io/nats.go from 1.39.0 to 1.39.1 in /sdks [beam] via GitHub
• 2025/04/04 Re: [PR] Fix FanOutStreamingEngineWorkerHarnessTest - testOnNewWorkerMetadata_redistributesBudget [beam] via GitHub
• 2025/04/04 Re: [PR] Bump golang.org/x/net from 0.35.0 to 0.37.0 in /sdks [beam] via GitHub
• 2025/04/04 Re: [PR] Fix the error for directory separator [beam] via GitHub
• 2025/04/04 Re: [PR] Fix Spanner NPE when withHost called with null or empty host [beam] via GitHub
• 2025/04/04 [PR] Fix the error for directory separator [beam] via GitHub
• 2025/04/04 Re: [PR] Fix the error for directory separator [beam] via GitHub
• 2025/04/04 [PR] plumb grpc flow control settings via UserWorkerRunnerV1Settings [beam] via GitHub
• 2025/04/04 [PR] Fix PostCommit TransformService Direct job [beam] via GitHub
• 2025/04/04 [PR] SnowflakeIO: filter on db and schema when searching for existing table [beam] via GitHub
• 2025/04/04 [I] [Bug]: ReadFromKafkaViaSDF does not set coder when using withValueDeserializerAndCoder [beam] via GitHub
• 2025/04/04 Re: [PR] do not block other threads from health checking if a stream is blocked [beam] via GitHub
• 2025/04/04 Re: [PR] [Python] File staging to user worker support [beam] via GitHub
• 2025/04/04 Re: [PR] [Dataflow Streaming] Don't share windmill stream pools between different commit threads [beam] via GitHub
• 2025/04/04 Re: [PR] [Dataflow Streaming] Don't share windmill stream pools between different commit threads [beam] via GitHub
• 2025/04/04 Re: [PR] [Dataflow Streaming] Don't share windmill stream pools between different commit threads [beam] via GitHub
• 2025/04/04 [PR] [Dataflow Streaming] Don't share windmill stream pools between different commit threads [beam] via GitHub
• 2025/04/04 Re: [PR] [Dataflow Streaming] Don't share windmill stream pools between different commit threads [beam] via GitHub
• 2025/04/04 [PR] Fix Spanner NPE when withHost called with null or empty host [beam] via GitHub
• 2025/04/04 Re: [PR] test commit [beam] via GitHub
• 2025/04/04 Re: [I] [Feature Request]: Yaml JdbcIO partitioning [beam] via GitHub
• 2025/04/04 Re: [PR] Fix incorrect nullness in FlinkJobInvoker and JobInvoker [beam] via GitHub
• 2025/04/04 Re: [PR] Bump org.hamcrest:hamcrest from 2.2 to 3.0 [beam-starter-java] via GitHub
• 2025/04/04 Re: [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] via GitHub
• 2025/04/04 Re: [I] [Bug]: beam.Map function outputs no data after beam.GroupByKey using DataflowRunner [beam] via GitHub
• 2025/04/04 Re: [PR] [DO NOT MERGE] Removed < 1.66 for grpcio [beam] via GitHub
• 2025/04/04 Re: [PR] Bump GoogleAdsIO to v19 [beam] via GitHub
• 2025/04/04 Re: [PR] Add STRING format to ReadFromKafka schema transform. [beam] via GitHub
• 2025/04/04 Re: [PR] Upgrade Iceberg BQMS version [beam] via GitHub
• 2025/04/04 [I] The PostCommit Java Jpms Dataflow Java17 job is flaky [beam] via GitHub
• 2025/04/04 Re: [PR] Removing snappy adding crc32c [beam] via GitHub
• 2025/04/04 [PR] <Draft> fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] via GitHub
• 2025/04/04 Re: [I] [Failing Test]: AttributeError for MaybeReshuffle in Python SDK [beam] via GitHub
• 2025/04/04 Re: [PR] Revert "Support directory separator for Python local filesystem" [beam] via GitHub
• 2025/04/04 Re: [PR] Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/04 [PR] Fn Runner Watermark issue [beam] via GitHub
• 2025/04/04 [PR] [Java] Improve Java FnStatus page to include bundle start time, oldest bundles by start time, and total bundles. [beam] via GitHub
• 2025/04/04 Re: [PR] Bump org.sonarqube from 3.0 to 6.1.0.5360 [beam] via GitHub
• 2025/04/04 [PR] Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/04 [PR] Fix postcommit python flaky tests [beam] via GitHub
• 2025/04/04 Re: [PR] warning for copy_tests_from_docs [beam] via GitHub
• 2025/04/04 Re: [PR] Fix link typos [beam] via GitHub
• 2025/04/04 Re: [PR] [IcebergIO] Add dataflow tests with and without managed experiment [beam] via GitHub
• 2025/04/04 Re: [I] The Java Tests job is flaky [beam] via GitHub
• 2025/04/04 Re: [PR] Enabling xlang utilization for SQS read functionality [beam] via GitHub
• 2025/04/04 Re: [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] via GitHub
• 2025/04/04 Re: [PR] [Managed Iceberg] unbounded source [beam] via GitHub
• 2025/04/04 Re: [PR] [Python] Add caching for BigQuery table definitions [beam] via GitHub
• 2025/04/04 Re: [PR] Feature: Yaml JdbcIO partitioning for ReadRows [beam] via GitHub
• 2025/04/04 Re: [PR] Bump org.apache.maven.plugins:maven-compiler-plugin from 3.10.1 to 3.14.0 [beam-starter-java] via GitHub
• 2025/04/04 Re: [PR] Add sdf kafka poll latencies [beam] via GitHub
• 2025/04/04 Re: [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work with WRITE_TRUNCATE write disposition (#34247) [beam] via GitHub
• 2025/04/04 Re: [PR] [AnomalyDetection] Refactor and improve Specifiable [beam] via GitHub
• 2025/04/04 Re: [PR] Clickhouse IT RM JDBC fix + ClickHouseRowsCheck [beam] via GitHub
• 2025/04/04 Re: [PR] Bump GoogleAdsIO to v19 [beam] via GitHub
• 2025/04/04 Re: [PR] [DO NOT MERGE] Prototype RemoteModelHandler base class [beam] via GitHub
• 2025/04/04 [PR] Add new resource hints: max active dofn per worker [beam] via GitHub
• 2025/04/04 [PR] Perform correct release version validation [beam] via GitHub
• 2025/04/04 Re: [PR] Add sdf kafka poll latencies [beam] via GitHub
• 2025/04/04 Re: [PR] [Java] Add Gauge Metric Extraction to DataflowMetrics [beam] via GitHub
• 2025/04/04 Re: [PR] add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… [beam] via GitHub
• 2025/04/04 [PR] Add an v-2.XX.0-RC00 when release branch is cut to enable git describe [beam] via GitHub
• 2025/04/04 [PR] improve yaml schema validation error message [beam] via GitHub
• 2025/04/04 [I] The PostCommit Go Dataflow ARM job is flaky [beam] via GitHub
• 2025/04/04 Re: [PR] Aggregation option in Kinesis Writer Python sdk [beam] via GitHub
• 2025/04/04 Re: [PR] Feature: Yaml JdbcIO partitioning for ReadRows [beam] via GitHub
• 2025/04/04 Re: [PR] Mention __init__.py, which is customary for packages. [beam] via GitHub
• 2025/04/04 Re: [PR] add generics support to AutoValueUtils helpers [beam] via GitHub
• 2025/04/04 Re: [PR] Remove social media pieces from release guide [beam] via GitHub
• 2025/04/04 Re: [PR] Auto-enable allowDuplicates for Redistribute with ALO streaming mode [beam] via GitHub
• 2025/04/04 Re: [I] [Feature Request]: CloudSQL Enrichment Handler [beam] via GitHub
• 2025/04/04 Re: [PR] [WIP] [Do not Merge] [Dataflow Streaming] Support for using virtual harness threads [beam] via GitHub
• 2025/04/04 Re: [PR] Bump golang.org/x/net from 0.35.0 to 0.36.0 in /sdks [beam] via GitHub
• 2025/04/04 Re: [PR] Fix Republish Released Docker Images workflow [beam] via GitHub
• 2025/04/04 Re: [PR] Add an v-2.XX.0-RC00 when release branch is cut to enable git describe [beam] via GitHub
• 2025/04/04 Re: [PR] add vendor to manually shutdown and restart GetWorkerMetadataStream to prevent DEADLINE_EXCEEDED errors [beam] via GitHub
• 2025/04/04 Re: [PR] Fix Spanner NPE when withHost called with null or empty host [beam] via GitHub
• 2025/04/04 [PR] [ManagedIO] Fail expansion when encountering extra or unknown configuration [beam] via GitHub
• 2025/04/04 Re: [PR] Introduce RemoteModelHandler abstract base class [beam] via GitHub
• 2025/04/04 Re: [PR] Add reducers for threading.Lock and EnumDescriptor. [beam] via GitHub

• Earlier messages
• Later messages