github  

Messages by Date

• 2025/04/14 Re: [PR] Use cached prism binary without re-unzipping by default. [beam] via GitHub
• 2025/04/14 Re: [PR] Bump golang.org/x/crypto from 0.31.0 to 0.35.0 [beam-starter-go] via GitHub
• 2025/04/14 Re: [I] [yaml] Normalize TFRecordIO [beam] via GitHub
• 2025/04/14 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/14 Re: [PR] Bump golang.org/x/crypto from 0.31.0 to 0.35.0 [beam-starter-go] via GitHub
• 2025/04/14 Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] via GitHub
• 2025/04/14 Re: [PR] Bump @octokit/request, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/14 Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.0 to 2.11.1 in /sdks [beam] via GitHub
• 2025/04/14 [PR] Bump golang.org/x/crypto from 0.31.0 to 0.35.0 [beam-starter-go] via GitHub
• 2025/04/14 Re: [PR] Fix The PostCommit XVR Flink job [beam] via GitHub
• 2025/04/14 Re: [PR] Bump golang.org/x/crypto from 0.21.0 to 0.35.0 in /.test-infra/mock-apis [beam] via GitHub
• 2025/04/14 [PR] Bump golang.org/x/crypto from 0.21.0 to 0.35.0 in /.test-infra/mock-apis [beam] via GitHub
• 2025/04/14 Re: [PR] consume flow control settings updates from job settings [beam] via GitHub
• 2025/04/14 Re: [PR] Fix incorrect nullness in FlinkJobInvoker and JobInvoker [beam] via GitHub
• 2025/04/14 Re: [I] The PostCommit XVR Flink job is flaky [beam] via GitHub
• 2025/04/14 Re: [PR] Fix The PostCommit XVR Flink job [beam] via GitHub
• 2025/04/14 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fail Fast if Resources Do Not Exist in Kafka Cluster" [beam] via GitHub
• 2025/04/14 Re: [PR] consume flow control settings updates from job settings [beam] via GitHub
• 2025/04/14 Re: [PR] consume flow control settings updates from job settings [beam] via GitHub
• 2025/04/14 Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] via GitHub
• 2025/04/14 Re: [PR] Fix The PostCommit XVR Flink job [beam] via GitHub
• 2025/04/14 Re: [PR] Fix GCP auth step for GitHub Actions workflows [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fail Fast if Resources Do Not Exist in Kafka Cluster" [beam] via GitHub
• 2025/04/14 [PR] Revert "Fail Fast if Resources Do Not Exist in Kafka Cluster" [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] via GitHub
• 2025/04/14 [I] [Bug]: KafkaIO unbounded read requires kafka connection on pipeline submission time [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fail Fast if Resources Do Not Exist in Kafka Cluster" [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fail Fast if Resources Do Not Exist in Kafka Cluster" [beam] via GitHub
• 2025/04/14 Re: [PR] sdks/python: enrich data with CloudSQL [beam] via GitHub
• 2025/04/14 Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] via GitHub
• 2025/04/14 Re: [PR] Preserve pane index through reshuffle. [beam] via GitHub
• 2025/04/14 Re: [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] via GitHub
• 2025/04/14 [PR] Activate service account for Publish Beam SDK Snapshots workflow [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] via GitHub
• 2025/04/14 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] via GitHub
• 2025/04/14 [PR] Activate service account for Publish Beam SDK Snapshots workflow [beam] via GitHub
• 2025/04/14 Re: [PR] Activate service account for Publish Beam SDK Snapshots workflow [beam] via GitHub
• 2025/04/14 Re: [PR] [KafkaIO] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] via GitHub
• 2025/04/14 [PR] Fix The PostCommit XVR Flink job [beam] via GitHub
• 2025/04/14 Re: [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] via GitHub
• 2025/04/14 Re: [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] via GitHub
• 2025/04/14 Re: [PR] Update run_rc_validation_python_mobile_gaming.yml [beam] via GitHub
• 2025/04/14 Re: [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] via GitHub
• 2025/04/14 Re: [PR] Fix GCP auth step for GitHub Actions workflows [beam] via GitHub
• 2025/04/14 [PR] Revert "Fix GCP auth step for GitHub Actions workflows" [beam] via GitHub
• 2025/04/14 Re: [PR] Fix GCP auth step for GitHub Actions workflows [beam] via GitHub
• 2025/04/14 [I] [Bug]: org.apache.beam.sdk.util.construction.BeamUrns.getUrn fails when trying to parse Protobuf messages [beam] via GitHub
• 2025/04/14 Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] via GitHub
• 2025/04/14 Re: [PR] Fix GCP auth step for GitHub Actions workflows [beam] via GitHub
• 2025/04/14 Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] via GitHub
• 2025/04/14 Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] via GitHub
• 2025/04/14 Re: [PR] [Python] Fix WriteToBigQuery transform using CopyJob does not work with WRITE_TRUNCATE write disposition (#34247) [beam] via GitHub
• 2025/04/14 Re: [PR] Add support for top-level table properties table creation [beam] via GitHub
• 2025/04/14 Re: [PR] Upgrade to hive 4.0.1 [beam] via GitHub
• 2025/04/14 Re: [I] [Bug][Prism]: Colab cannot run PrismRunner multiple times [beam] via GitHub
• 2025/04/14 Re: [PR] add generics support to AutoValueUtils helpers [beam] via GitHub
• 2025/04/14 Re: [PR] Rethrowing Exception from CassandraIO's ReadFn [beam] via GitHub
• 2025/04/14 Re: [PR] BigQueryIO uniformize direct and export reads [beam] via GitHub
• 2025/04/14 Re: [PR] Update MongoDB driver to mongodb-driver-legacy:5.4.0 [beam] via GitHub
• 2025/04/14 Re: [PR] SnowflakeIO: filter on db and schema when searching for existing table [beam] via GitHub
• 2025/04/14 Re: [PR] Fix GCP auth step for GitHub Actions workflows [beam] via GitHub
• 2025/04/14 [PR] Fix GCP auth step for GitHub Actions workflows [beam] via GitHub
• 2025/04/13 [PR] Make prism server a singleton [beam] via GitHub
• 2025/04/13 Re: [PR] test commit [beam] via GitHub
• 2025/04/13 Re: [PR] test commit [beam] via GitHub
• 2025/04/13 Re: [PR] test commit [beam] via GitHub
• 2025/04/13 Re: [PR] FORKING - Apache/Beam Optimization and Clean code. [beam] via GitHub
• 2025/04/13 Re: [PR] Update run_rc_validation_python_mobile_gaming.yml [beam] via GitHub
• 2025/04/13 Re: [PR] FORKING - Apache/Beam Optimization and Clean code. [beam] via GitHub
• 2025/04/13 Re: [PR] FORKING - Apache/Beam Optimization and Clean code. [beam] via GitHub
• 2025/04/13 Re: [PR] FORKING - Apache/Beam Optimization and Clean code. [beam] via GitHub
• 2025/04/13 [PR] FORKING - Apache/Beam Optimization and Clean code. [beam] via GitHub
• 2025/04/13 [PR] Update run_rc_validation_python_mobile_gaming.yml [beam] via GitHub
• 2025/04/13 Re: [PR] [docs] Add new Python multi-lang quickstart using the SchemaTransform framework [beam] via GitHub
• 2025/04/13 Re: [PR] [docs] Add new Python multi-lang quickstart using the SchemaTransform framework [beam] via GitHub
• 2025/04/13 Re: [PR] use the script when validating the BQ table [beam] via GitHub
• 2025/04/13 Re: [PR] added ddl to SqlTransform [beam] via GitHub
• 2025/04/13 Re: [I] [Task]: Create RC validation workflows [beam] via GitHub
• 2025/04/13 Re: [PR] Fail Fast if Resources Do Not Exist in Kafka Cluster [beam] via GitHub
• 2025/04/12 Re: [PR] sdks/python: enrich data with CloudSQL [beam] via GitHub
• 2025/04/12 Re: [PR] sdks/python: enrich data with CloudSQL [beam] via GitHub
• 2025/04/12 Re: [PR] Fix: Deduplicate mutations in flushBatch to prevent Datastore commit … [beam] via GitHub
• 2025/04/12 Re: [PR] Fix: Deduplicate mutations in flushBatch to prevent Datastore commit … [beam] via GitHub
• 2025/04/12 Re: [PR] Fix: Deduplicate mutations in flushBatch to prevent Datastore commit … [beam] via GitHub
• 2025/04/12 [PR] Fix: Deduplicate mutations in flushBatch to prevent Datastore commit … [beam] via GitHub
• 2025/04/12 Re: [I] [Bug]: DatastoreIO.Write fails multiple mutations of same entity on `finishBundle` [beam] via GitHub
• 2025/04/12 Re: [PR] Minor fixes to yaml testing docs. [beam] via GitHub
• 2025/04/12 Re: [PR] use the script when validating the BQ table [beam] via GitHub
• 2025/04/12 [PR] Minor fixes to yaml testing docs. [beam] via GitHub
• 2025/04/12 [PR] use the script when validating the BQ table [beam] via GitHub
• 2025/04/12 Re: [PR] [KafkaIO] Improve caching in backlog estimation and processing [beam] via GitHub
• 2025/04/12 Re: [PR] [Java]Add Map Type Support to JsonToRow Transformer [beam] via GitHub
• 2025/04/12 Re: [PR] [KafkaIO] Update tracker and watermark for non-visible progress [beam] via GitHub
• 2025/04/12 Re: [PR] Use cached prism binary without re-unzipping by default. [beam] via GitHub
• 2025/04/11 Re: [PR] Use cached prism binary without re-unzipping by default. [beam] via GitHub
• 2025/04/11 Re: [PR] Use component coder when handling nullable coder in prism. [beam] via GitHub
• 2025/04/11 [PR] Use component coder when decoding with nullable coder in prism. [beam] via GitHub
• 2025/04/11 Re: [PR] Use component coder when handling nullable coder in prism. [beam] via GitHub
• 2025/04/11 Re: [PR] [KafkaIO] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] via GitHub
• 2025/04/11 Re: [PR] [KafkaIO] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] via GitHub
• 2025/04/11 Re: [PR] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder [beam] via GitHub
• 2025/04/11 Re: [PR] added ddl to SqlTransform [beam] via GitHub
• 2025/04/11 Re: [PR] added ddl to SqlTransform [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] via GitHub
• 2025/04/11 Re: [PR] Disable logical type cast of fastavro [beam] via GitHub
• 2025/04/11 Re: [PR] added ddl to SqlTransform [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] via GitHub
• 2025/04/11 Re: [PR] [IcebergIO] Apply delete/update filter when reading [beam] via GitHub
• 2025/04/11 Re: [PR] [IcebergIO] Apply delete/update filter when reading [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] via GitHub
• 2025/04/11 Re: [PR] added ddl to SqlTransform [beam] via GitHub
• 2025/04/11 [PR] added ddl to SqlTransform [beam] via GitHub
• 2025/04/11 Re: [PR] Sql transform [beam] via GitHub
• 2025/04/11 [I] [Bug]: SqlTransformSchemaTransformProvider.java does not work [beam] via GitHub
• 2025/04/11 Re: [PR] Ensure SpannerConfig uses correct default when host set to null [beam] via GitHub
• 2025/04/11 Re: [PR] Disable logical type cast of fastavro [beam] via GitHub
• 2025/04/11 Re: [PR] Disable logical type cast of fastavro [beam] via GitHub
• 2025/04/11 Re: [PR] Python PTransform wrapper for AWS SQS [beam] via GitHub
• 2025/04/11 Re: [PR] Python PTransform wrapper for AWS SQS [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 [PR] Enable prism by default (where supported) [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] Request to use BASIC enum when calling tables.get() in BigQuery #34075 [beam] via GitHub
• 2025/04/11 Re: [PR] Update illustration for cut_release_branch workflow [beam] via GitHub
• 2025/04/11 Re: [PR] Update illustration for cut_release_branch workflow [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] [Java] Add InsertRetryPolicy for non-successful BigQuery insertAll responses [beam] via GitHub
• 2025/04/11 Re: [PR] Update illustration for cut_release_branch workflow [beam] via GitHub
• 2025/04/11 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/11 Re: [PR] Request to use BASIC enum when calling tables.get() in BigQuery #34075 [beam] via GitHub
• 2025/04/11 Re: [PR] Add YamlTransform to the Java SDK. [beam] via GitHub
• 2025/04/11 Re: [PR] Fn Runner Watermark issue [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SpannerIO does not use correct endpoint when specified host is null or blank [beam] via GitHub
• 2025/04/11 Re: [PR] Ensure SpannerConfig uses correct default when host set to null [beam] via GitHub
• 2025/04/11 Re: [I] [Bug]: SpannerIO does not use correct endpoint when specified host is null or blank [beam] via GitHub
• 2025/04/11 Re: [PR] Fn Runner Watermark issue [beam] via GitHub
• 2025/04/11 Re: [PR] Bump @octokit/request-error, @actions/github and @octokit/rest in /scripts/ci/pr-bot [beam] via GitHub
• 2025/04/11 Re: [PR] Clickhouse IT RM JDBC fix + ClickHouseRowsCheck [beam] via GitHub
• 2025/04/11 Re: [PR] [Java] Add InsertRetryPolicy for non-successful BigQuery insertAll responses [beam] via GitHub
• 2025/04/11 Re: [PR] SnowflakeIO: filter on db and schema when searching for existing table [beam] via GitHub
• 2025/04/11 Re: [PR] Disable logical type cast of fastavro [beam] via GitHub
• 2025/04/11 Re: [I] [RRIO]: Create and update website examples using RequestResponseIO using the Python SDK [beam] via GitHub
• 2025/04/10 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.14 in /sdks [beam] via GitHub
• 2025/04/10 Re: [PR] Bump cloud.google.com/go/spanner from 1.78.0 to 1.79.0 in /sdks [beam] via GitHub
• 2025/04/10 [I] The Playground CI Nightly job is flaky [beam] via GitHub
• 2025/04/10 Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
• 2025/04/10 [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.14 in /sdks [beam] via GitHub
• 2025/04/10 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.13 in /sdks [beam] via GitHub
• 2025/04/10 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.13 in /sdks [beam] via GitHub
• 2025/04/10 [PR] Bump cloud.google.com/go/spanner from 1.78.0 to 1.79.0 in /sdks [beam] via GitHub
• 2025/04/10 Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
• 2025/04/10 Re: [PR] Python PTransform wrapper for AWS SQS [beam] via GitHub
• 2025/04/10 Re: [PR] Python PTransform wrapper for AWS SQS [beam] via GitHub
• 2025/04/10 Re: [PR] Handle pickling top-level enums. [beam] via GitHub
• 2025/04/10 Re: [I] [Bug]: Prism overwrites coders while handling flatten [beam] via GitHub
• 2025/04/10 Re: [I] [Bug]: Prism overwrites coders while handling flatten [beam] via GitHub
• 2025/04/10 [I] [Bug]: DatastoreIO.Write fails multiple mutations of same entity on `finishBundle` [beam] via GitHub
• 2025/04/10 Re: [I] [Bug]: DatastoreIO.Write fails multiple mutations of same entity on `finishBundle` [beam] via GitHub
• 2025/04/10 Re: [I] [prism] Python Validates Runner (test_pack_combiners) - Unknown Coder not being processed (tuple) [beam] via GitHub
• 2025/04/10 Re: [PR] Fix coder parsing for any non-standard composite coder types [beam] via GitHub
• 2025/04/10 [PR] Update link in yaml-providers.md [beam] via GitHub
• 2025/04/10 Re: [PR] Update run_rc_validation_go_wordcount.yml [beam] via GitHub
• 2025/04/10 Re: [PR] Sql transform [beam] via GitHub
• 2025/04/10 Re: [PR] Handle pickling top-level enums. [beam] via GitHub
• 2025/04/10 [PR] Bump github.com/nats-io/nats-server/v2 from 2.11.0 to 2.11.1 in /sdks [beam] via GitHub
• 2025/04/10 Re: [I] [Bug]: avro_dict_to_beam_row negative integer incorrectly converts to uint [beam] via GitHub
• 2025/04/10 Re: [I] [Bug]: Bigquery python streaming insertAll SSLError leads to stuck streaming job [beam] via GitHub
• 2025/04/10 Re: [PR] Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally [beam] via GitHub
• 2025/04/10 [PR] [DO NOT MERGE] try parquet_version 1.51.1 [beam] via GitHub
• 2025/04/10 Re: [PR] Key by paneindex and reshuffle before loading files. [beam] via GitHub
• 2025/04/10 [PR] [extensions-proto] Return correct TypeDescriptor for ProtoCoder (#34561) [beam] via GitHub
• 2025/04/10 Re: [PR] Fix coder corruption in prism while handling flatten [beam] via GitHub
• 2025/04/10 Re: [PR] [IcebergIO] Apply delete/update filter when reading [beam] via GitHub
• 2025/04/10 Re: [PR] Update illustration for cut_release_branch workflow [beam] via GitHub
• 2025/04/10 Re: [PR] [WIP] Open Telemetry Tracing for java sdk [beam] via GitHub
• 2025/04/10 Re: [PR] Fix PostCommit Python Dependency and PreCommit Python ML tests [beam] via GitHub
• 2025/04/10 Re: [PR] Fix postcommit python flaky tests [beam] via GitHub
• 2025/04/10 Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.29.10 to 1.29.13 in /sdks [beam] via GitHub
• 2025/04/10 Re: [PR] consume flow control settings updates from job settings [beam] via GitHub
• 2025/04/10 Re: [PR] Update illustration for cut_release_branch workflow [beam] via GitHub
• 2025/04/10 Re: [PR] Update illustration for cut_release_branch workflow [beam] via GitHub
• 2025/04/10 Re: [PR] Remove ZetaSQL from nexmark and tpcds benchmark suites [beam] via GitHub
• 2025/04/10 Re: [PR] Deprecate ZetaSQL [beam] via GitHub
• 2025/04/10 Re: [PR] Fix coder corruption in prism while handling flatten [beam] via GitHub
• 2025/04/10 Re: [PR] Spark Runner : Support for Streaming side-inputs for Spark Runner [beam] via GitHub
• 2025/04/10 Re: [PR] Add documentation for the Go Direct Runner to Direct Runner guide Fixes: #21904 [beam] via GitHub
• 2025/04/10 Re: [PR] Normalize tf record io [beam] via GitHub
• 2025/04/10 Re: [PR] Add YamlTransform to the Java SDK. [beam] via GitHub
• 2025/04/10 Re: [PR] Python PTransform wrapper for AWS SQS [beam] via GitHub
• 2025/04/10 Re: [PR] Preserve pane index through reshuffle. [beam] via GitHub
• 2025/04/10 Re: [PR] Fix coder parsing for any non-standard composite coder types [beam] via GitHub

• Earlier messages
• Later messages