github  

Messages by Thread

• [PR] Add cloudpickle default to changes.md. [beam] via GitHub
  • Re: [PR] Add cloudpickle default to changes.md. [beam] via GitHub
  • Re: [PR] Add cloudpickle default to changes.md. [beam] via GitHub
• [I] [Task]: Tracking cloudpickle issues [beam] via GitHub
  • Re: [I] [Task]: Tracking cloudpickle issues [beam] via GitHub
• [PR] DO NOT MERGE: demonstrating impact of OutputBuilder [beam] via GitHub
  • Re: [PR] DO NOT MERGE: demonstrating impact of OutputBuilder [beam] via GitHub
• [PR] Revert "Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv…" [beam] via GitHub
  • Re: [PR] Revert "Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv…" [beam] via GitHub
  • Re: [PR] Revert "Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv…" [beam] via GitHub
• Re: [PR] Change ReadFromKafkaViaSDF to use Create instead of deprecated Impulse transform. [beam] via GitHub
• [PR] Correcting the pipeline object definition [beam] via GitHub
  • Re: [PR] Correcting the pipeline object definition [beam] via GitHub
  • Re: [PR] Correcting the pipeline object definition [beam] via GitHub
• [PR] Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv… [beam] via GitHub
  • Re: [PR] Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv… [beam] via GitHub
  • Re: [PR] Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv… [beam] via GitHub
  • Re: [PR] Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv… [beam] via GitHub
  • Re: [PR] Correcting regex for _PROJECT_PATTERN for bigquery table name (resolv… [beam] via GitHub
• Re: [I] [Bug]: bigquery_tools.parse_table_reference accepts invalid identifier [beam] via GitHub
  • Re: [I] [Bug]: bigquery_tools.parse_table_reference accepts invalid identifier [beam] via GitHub
  • Re: [I] [Bug]: bigquery_tools.parse_table_reference accepts invalid identifier [beam] via GitHub
  • Re: [I] [Bug]: bigquery_tools.parse_table_reference accepts invalid identifier [beam] via GitHub
  • Re: [I] [Bug]: bigquery_tools.parse_table_reference accepts invalid identifier [beam] via GitHub
  • Re: [I] [Bug]: bigquery_tools.parse_table_reference accepts invalid identifier [beam] via GitHub
• Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Support unkeyed input for the transform. [beam] via GitHub
• [PR] fix typos [beam] via GitHub
  • Re: [PR] fix typos [beam] via GitHub
• [PR] Add empty outputs to notebooks which can't run without help [beam] via GitHub
  • Re: [PR] Add empty outputs to notebooks which can't run without help [beam] via GitHub
  • Re: [PR] Add empty outputs to notebooks which can't run without help [beam] via GitHub
  • Re: [PR] Add empty outputs to notebooks which can't run without help [beam] via GitHub
• Re: [I] Merge rather than override resource specs on substitution. [beam] via GitHub
  • Re: [I] Merge rather than override resource specs on substitution. [beam] via GitHub
• [I] Readfrom kafka not supporting in python [beam] via GitHub
• [PR] Allow psycopg2 2.9.10 [beam] via GitHub
  • Re: [PR] Allow psycopg2 2.9.10 [beam] via GitHub
• [I] [Bug]: The beam task consumes Kafka, and then the runner is Flinkrunner. After the job recovers from the checkpoint, it repeatedly consumes Kafka messages [beam] via GitHub
  • Re: [I] [Bug]: The beam task consumes Kafka, and then the runner is Flinkrunner. After the job recovers from the checkpoint, it repeatedly consumes Kafka messages [beam] via GitHub
• [PR] [DO NOT MERGE] Support newer versions of PyArrow [beam] via GitHub
• [PR] [Dataflow Streaming] Remove unused quota throttling metrics from windmill streams [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Remove unused quota throttling metrics from windmill streams [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] Remove unused quota throttling metrics from windmill streams [beam] via GitHub
• [PR] Fix typecoders_test.py formatting [beam] via GitHub
  • Re: [PR] Fix typecoders_test.py formatting [beam] via GitHub
  • Re: [PR] Fix typecoders_test.py formatting [beam] via GitHub
  • Re: [PR] Fix typecoders_test.py formatting [beam] via GitHub
• [PR] Specify cryptography version. [beam] via GitHub
  • Re: [PR] Specify cryptography version. [beam] via GitHub
  • Re: [PR] Specify cryptography version. [beam] via GitHub
  • Re: [PR] Specify cryptography version. [beam] via GitHub
  • Re: [PR] Specify cryptography version. [beam] via GitHub
• [PR] Prevent ValueError when passing resource_hints in StandardOptions(resolves #34879) [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
  • Re: [PR] Prevent ValueError when passing resource_hints in StandardOptions [beam] via GitHub
• [PR] Bump golang.org/x/net from 0.39.0 to 0.40.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump golang.org/x/net from 0.39.0 to 0.40.0 in /sdks [beam] via GitHub
• [PR] Update the notebook. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Update notebook. [beam] via GitHub
  • Re: [PR] [AnomalyDetection] Update notebook. [beam] via GitHub
• [PR] Refactor: separate PairWithRestriction from FnApiDoFnRunner [beam] via GitHub
  • Re: [PR] Refactor: separate PairWithRestriction from FnApiDoFnRunner [beam] via GitHub
  • Re: [PR] Refactor: separate PairWithRestriction from FnApiDoFnRunner [beam] via GitHub
  • Re: [PR] Refactor: separate PairWithRestriction from FnApiDoFnRunner [beam] via GitHub
• [PR] Reference managed-io page in our docs [beam] via GitHub
  • Re: [PR] Reference managed-io page in our docs [beam] via GitHub
  • Re: [PR] Reference managed-io page in our docs [beam] via GitHub
  • Re: [PR] Reference managed-io page in our docs [beam] via GitHub
  • Re: [PR] Reference managed-io page in our docs [beam] via GitHub
  • Re: [PR] Reference managed-io page in our docs [beam] via GitHub
  • Re: [PR] Reference managed-io page in our docs [beam] via GitHub
• Re: [PR] Remove type suppressions from MetricsPusher and MetricsSink [beam] via GitHub
  • Re: [PR] Remove type suppressions from MetricsPusher and MetricsSink [beam] via GitHub
  • Re: [PR] Remove type suppressions from MetricsPusher and MetricsSink [beam] via GitHub
  • Re: [PR] Remove type suppressions from MetricsPusher and MetricsSink [beam] via GitHub
  • Re: [PR] Remove type suppressions from MetricsPusher and MetricsSink [beam] via GitHub
• Re: [PR] [IcebergIO] Support column pruning [beam] via GitHub
  • Re: [PR] [IcebergIO] Support column pruning [beam] via GitHub
  • Re: [PR] [IcebergIO] Support column pruning [beam] via GitHub
  • Re: [PR] [IcebergIO] Support column pruning [beam] via GitHub
• [PR] Bump Vertex AI Embeddings test model to new version [beam] via GitHub
  • Re: [PR] Bump Vertex AI Embeddings test model to new version [beam] via GitHub
  • Re: [PR] Bump Vertex AI Embeddings test model to new version [beam] via GitHub
  • Re: [PR] Bump Vertex AI Embeddings test model to new version [beam] via GitHub
  • Re: [PR] Bump Vertex AI Embeddings test model to new version [beam] via GitHub
• [PR] Fix minor issues in various PTransformRunner classes [beam] via GitHub
  • Re: [PR] Fix minor issues in various PTransformRunner classes [beam] via GitHub
  • Re: [PR] Fix minor issues in various PTransformRunner classes [beam] via GitHub
  • Re: [PR] Fix minor issues in various PTransformRunner classes [beam] via GitHub
  • Re: [PR] Fix minor issues in various PTransformRunner classes [beam] via GitHub
• [I] [Bug]: ValueError: Resource hint min_ram has invalid value None when setting resource_hints in StandardOptions [beam] via GitHub
  • Re: [I] [Bug]: ValueError: Resource hint min_ram has invalid value None when setting resource_hints in StandardOptions [beam] via GitHub
• Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
  • Re: [PR] [IcebergIO] Add Iceberg SQL table provider and tests [beam] via GitHub
• [PR] Fix flaky BoundedQueueExecutor test [beam] via GitHub
  • Re: [PR] Fix flaky BoundedQueueExecutor test [beam] via GitHub
  • Re: [PR] Fix flaky BoundedQueueExecutor test [beam] via GitHub
  • Re: [PR] Fix flaky BoundedQueueExecutor test [beam] via GitHub
  • Re: [PR] Fix flaky BoundedQueueExecutor test [beam] via GitHub
• [PR] Fix pr-bot workflows [beam] via GitHub
  • Re: [PR] Fix pr-bot workflows [beam] via GitHub
• [PR] Bump google.golang.org/api from 0.231.0 to 0.232.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.231.0 to 0.232.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.231.0 to 0.232.0 in /sdks [beam] via GitHub
• Re: [I] [Bug]: Java expansion service does not respect the namespace for all environments. [beam] via GitHub
• [PR] Replace deprecated model version. [beam] via GitHub
  • Re: [PR] Replace deprecated model version. [beam] via GitHub
  • Re: [PR] Replace deprecated model version. [beam] via GitHub
  • Re: [PR] Replace deprecated model version. [beam] via GitHub
  • Re: [PR] Replace deprecated model version. [beam] via GitHub
• [PR] Cloudpickle deterministic [beam] via GitHub
  • Re: [PR] Cloudpickle deterministic [beam] via GitHub
• Re: [I] Write just one file per window with WriteToFiles transform [beam] via GitHub
• Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
  • Re: [PR] 34749 added cache for avro coder to reduce memory footprint [beam] via GitHub
• [PR] reorder opt-out review comment [beam] via GitHub
  • Re: [PR] reorder opt-out review comment [beam] via GitHub
  • Re: [PR] reorder opt-out review comment [beam] via GitHub
  • Re: [PR] reorder opt-out review comment [beam] via GitHub
  • Re: [PR] reorder opt-out review comment [beam] via GitHub
• [PR] Add yapf version upgrade doc to discussion-docs for 2025 [beam] via GitHub
  • Re: [PR] Add yapf version upgrade doc to discussion-docs for 2025 [beam] via GitHub
  • Re: [PR] Add yapf version upgrade doc to discussion-docs for 2025 [beam] via GitHub
• [PR] Update trivial inference for Python 3.13 [beam] via GitHub
  • Re: [PR] Update trivial inference for Python 3.13 [beam] via GitHub
  • Re: [PR] Update trivial inference for Python 3.13 [beam] via GitHub
• Re: [I] [Bug]: Reshuffle with default windows encodes PaneInfo with FastPrmitivesCoder [beam] via GitHub
• [I] [Bug]: Spanner schemas with ARRAY<STRING(xxx)> fail to parse [beam] via GitHub
  • Re: [I] [Bug]: Spanner schemas with ARRAY<STRING(xxx)> fail to parse [beam] via GitHub
  • Re: [I] [Bug]: Spanner schemas with ARRAY<STRING(xxx)> fail to parse [beam] via GitHub
  • Re: [I] [Bug]: Spanner schemas with ARRAY<STRING(xxx)> fail to parse [beam] via GitHub
  • Re: [I] [Bug]: Spanner schemas with ARRAY<STRING(xxx)> fail to parse [beam] via GitHub
  • Re: [I] [Bug]: Spanner schemas with ARRAY<STRING(xxx)> fail to parse [beam] via GitHub
• [PR] fix: correct spanner column schema type parser [beam] via GitHub
  • Re: [PR] fix: correct spanner column schema type parser [beam] via GitHub
  • Re: [PR] fix: correct spanner column schema type parser [beam] via GitHub
  • Re: [PR] fix: correct spanner column schema type parser [beam] via GitHub
  • Re: [PR] fix: correct spanner column schema type parser [beam] via GitHub
  • [PR] fix: correct spanner column schema type parser [beam] via GitHub
  • Re: [PR] [release-2.65] Cherrypick PR #34867 to the release branch [beam] via GitHub
• [PR] Add label when PR gets reassigned [beam] via GitHub
  • Re: [PR] Add label when PR gets reassigned [beam] via GitHub
  • Re: [PR] Add label when PR gets reassigned [beam] via GitHub
• [PR] Update breaking changes with PaneInfoCoder change. [beam] via GitHub
  • Re: [PR] Update breaking changes with PaneInfoCoder change. [beam] via GitHub
  • Re: [PR] Update breaking changes with PaneInfoCoder change. [beam] via GitHub
• [PR] Encode paneinfo with PaneInfoCoder. (#34824) [beam] via GitHub
  • Re: [PR] Encode paneinfo with PaneInfoCoder. (#34824) [beam] via GitHub
  • Re: [PR] Encode paneinfo with PaneInfoCoder. (#34824) [beam] via GitHub
• Re: [PR] correcting array truncation logic (resolves #34276) [beam] via GitHub
• [PR] Bump @octokit/request-error and @octokit/rest in /scripts/ci/issue-report [beam] via GitHub
  • Re: [PR] Bump @octokit/request-error and @octokit/rest in /scripts/ci/issue-report [beam] via GitHub
  • Re: [PR] Bump @octokit/request-error and @octokit/rest in /scripts/ci/issue-report [beam] via GitHub
  • Re: [PR] Bump @octokit/request-error and @octokit/rest in /scripts/ci/issue-report [beam] via GitHub
• Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
  • Re: [PR] [IcebergIO] support selecting some fields to either keep or drop [beam] via GitHub
• [PR] [WIP] Update Error Prone for ThreadSafe analysis [beam] via GitHub
• [PR] Fix parquet-avro vulnerability in io expansion service [beam] via GitHub
  • Re: [PR] Fix parquet-avro vulnerability in io expansion service [beam] via GitHub

• Earlier messages