github  

Messages by Thread

• • Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] via GitHub
  • Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] via GitHub
  • Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] via GitHub
  • Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] via GitHub
  • Re: [PR] [BigQueryIO] Improve sharding for batch pipelines [beam] via GitHub
• [I] [GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge [beam] via GitHub
  • Re: [I] [GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge [beam] via GitHub
• Re: [I] [Bug]: Python BQ directrunner postcommits flake with KeyError: '__pyx_vtable__' [beam] via GitHub
  • Re: [I] [Bug]: Python BQ directrunner postcommits flake with KeyError: '__pyx_vtable__' [beam] via GitHub
• Re: [I] [Bug]: pytest retry configuration is not effective [beam] via GitHub
  • Re: [I] [Bug]: pytest retry configuration is not effective [beam] via GitHub
• Re: [I] [Task]: Fix hugging face ModelHandler top level imports [beam] via GitHub
  • Re: [I] [Task]: Fix hugging face ModelHandler top level imports [beam] via GitHub
• Re: [I] [Bug] [BQ Streaming Inserts]: Whole number in float field is treated like an int [beam] via GitHub
  • Re: [I] [Bug] [BQ Streaming Inserts]: Whole number in float field is treated like an int [beam] via GitHub
• Re: [I] [Feature Request]: Reduce FnApi error logs for processing that is cancelled for expected reasons [beam] via GitHub
  • Re: [I] [Feature Request]: Reduce FnApi error logs for processing that is cancelled for expected reasons [beam] via GitHub
• Re: [PR] Iceberg CDC streaming source [beam] via GitHub
  • Re: [PR] Iceberg CDC streaming source [beam] via GitHub
• Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
  • Re: [PR] Fix silent per-char iteration when DoFn returns str/bytes/dict [beam] via GitHub
• Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
  • Re: [PR] GCSFileSystem requires gcp extra at lookup time while S3FileSystem does not [beam] via GitHub
• Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
  • Re: [PR] [Dataflow Streaming] [Multi Key] Introduce KeyGroupWorkQueue and integrate with BoundedQueueExecutor [beam] via GitHub
• Re: [PR] Add DoFnRunner::finishKey() method [beam] via GitHub
  • Re: [PR] Add DoFnRunner::finishKey() method [beam] via GitHub
  • Re: [PR] Add DoFnRunner::finishKey() method [beam] via GitHub
  • Re: [PR] Add DoFnRunner::finishKey() method [beam] via GitHub
  • Re: [PR] Add DoFnRunner::finishKey() method [beam] via GitHub
• Re: [I] [Bug]: Type hints lost in core transforms [beam] via GitHub
  • Re: [I] [Bug]: Type hints lost in core transforms [beam] via GitHub
• Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] via GitHub
  • Re: [PR] [1/2] RAG: add OpenAI text embeddings [beam] via GitHub
• Re: [I] [Failing Test]: Pylint failed when hypothesis > 6.148.3 is used [beam] via GitHub
  • Re: [I] [Failing Test]: Pylint failed when hypothesis > 6.148.3 is used [beam] via GitHub
• Re: [I] [Failing Test]: Re-enable the skipped Change Stream Unit tests after refactor test code [beam] via GitHub
• Re: [I] [Bug]: SolaceIO seems to lose messages during Dataflow scaling/rebalancing events [beam] via GitHub
  • Re: [I] [Bug]: SolaceIO seems to lose messages during Dataflow scaling/rebalancing events [beam] via GitHub
• Re: [I] [Bug]: Dependency resolution is happening when installing latest version of apache-beam[gcp] [beam] via GitHub
  • Re: [I] [Bug]: Dependency resolution is happening when installing latest version of apache-beam[gcp] [beam] via GitHub
• Re: [I] Permission needs to be obtained before adding exceptions to the CSP [beam] via GitHub
  • Re: [I] Permission needs to be obtained before adding exceptions to the CSP [beam] via GitHub
• Re: [I] [Task]: Propagate context from windmill to windowedValue [beam] via GitHub
• Re: [PR] Update SpannerIO.java - comment documentation [beam] via GitHub
  • Re: [PR] Update SpannerIO.java - comment documentation [beam] via GitHub
• Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
  • Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
  • Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
  • Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
  • Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
  • Re: [PR] Fix temp table cleanup for continuous read in BigQueryIO [beam] via GitHub
• [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
  • Re: [PR] Update Gemini text classification to gemini-2.5-flash [beam] via GitHub
• Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
  • Re: [PR] [GSoC 2026] Kafka Streams runner — ExecutableStage (stateless ParDo) translator [beam] via GitHub
• [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang IO Direct job is flaky [beam] via GitHub
• Re: [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] via GitHub
  • Re: [I] The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky [beam] via GitHub
• Re: [I] runtime_type_check DoFn wrapper doesn't call setup and teardown [beam] via GitHub
  • Re: [I] runtime_type_check DoFn wrapper doesn't call setup and teardown [beam] via GitHub
  • Re: [I] runtime_type_check DoFn wrapper doesn't call setup and teardown [beam] via GitHub
• Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
  • Re: [PR] Implement Asynchronous wrapper for DoFn in Java SDK [beam] via GitHub
• Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add utils base, delete reader, and serializable files [beam] via GitHub
• [PR] [Iceberg CDC] Add Changelog readers and update resolver [beam] via GitHub
• Re: [PR] [WIP] Iceberg CDC streaming source [beam] via GitHub
• [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add Snapshot Changelog Scanner [beam] via GitHub
• [PR] defer ConstructionTimeTest fixtures to setUpClass [beam] via GitHub
  • Re: [PR] defer ConstructionTimeTest fixtures to setUpClass [beam] via GitHub
• [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Add watch for snapshots source [beam] via GitHub
• Re: [PR] Request service account credentials for GSoC 2026 - Hansel Tepal [beam] via GitHub
  • Re: [PR] Request service account credentials for GSoC 2026 - Hansel Tepal [beam] via GitHub
• Re: [PR] Fix cloudML TFT install avoiding pip ResolutionTooDeep [beam] via GitHub
  • Re: [PR] Fix cloudML TFT install avoiding pip ResolutionTooDeep [beam] via GitHub
  • Re: [PR] Fix cloudML TFT install avoiding pip ResolutionTooDeep [beam] via GitHub
• Re: [I] [Feature Request]: Iceberg IO Hash Distribution Mode Support for Spark Based Runners [beam] via GitHub
  • Re: [I] [Feature Request]: Iceberg IO Hash Distribution Mode Support for Spark Based Runners [beam] via GitHub
  • Re: [I] [Feature Request]: Iceberg IO Hash Distribution Mode Support for Spark Based Runners [beam] via GitHub
• Re: [PR] [Iceberg CDC] Import BaseIncrementalChangelogScan [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Import BaseIncrementalChangelogScan [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Import BaseIncrementalChangelogScan [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Import BaseIncrementalChangelogScan [beam] via GitHub
  • Re: [PR] [Iceberg CDC] Import BaseIncrementalChangelogScan [beam] via GitHub
• Re: [PR] Automate OpenTelemetry license entries in bomupgrader [beam] via GitHub
• Re: [PR] Side Input improvements [beam] via GitHub
  • Re: [PR] Side Input improvements [beam] via GitHub
  • Re: [PR] Side Input improvements [beam] via GitHub
• [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
  • Re: [PR] Preserve partitioning on temp FILE_LOADS tables [beam] via GitHub
• Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
  • Re: [PR] Support global sort and improve UDF overload resolution in Beam SQL [beam] via GitHub
• Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub
  • Re: [PR] Fix ensurepip bundled pip upgrade for Python 3.12+ [beam] via GitHub

• Later messages