github  

Messages by Thread

• • Re: [PR] Use trigger state to know if a window is new and optimize reads [beam] via GitHub
  • Re: [PR] Use trigger state to know if a window is new and optimize reads [beam] via GitHub
• Re: [PR] Optimze away WindmillWatermarkHold::clear when the cached hold is empty [beam] via GitHub
  • Re: [PR] Optimze away WindmillWatermarkHold::clear when the cached hold is empty [beam] via GitHub
  • Re: [PR] Optimze away WindmillWatermarkHold::clear when the cached hold is empty [beam] via GitHub
  • Re: [PR] Optimze away WindmillWatermarkHold::clear when the cached hold is empty [beam] via GitHub
• Re: [I] [Task]: Deprecate Java8 [beam] via GitHub
• [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
  • Re: [PR] Revert "Fix unhandled exception in KafkaIO SDF (#37449)" [beam] via GitHub
• [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
  • Re: [PR] Remove unused variable [beam] via GitHub
• [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
  • Re: [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
  • Re: [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
  • Re: [PR] Remove unused logTopicVerification field from GenerateKafkaSourceDesc… [beam] via GitHub
• Re: [PR] fix(python): Register all output pcollections of a transform rather than only ones that happened to be accessed in DoOutputsTuple [beam] via GitHub
  • Re: [PR] fix(python): Register all output pcollections of a transform rather than only ones that happened to be accessed in DoOutputsTuple [beam] via GitHub
• [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
  • Re: [PR] regenerate requirements and tweak versions based on prior or proposed changes [beam] via GitHub
• [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
  • Re: [PR] Add pipeline hash [beam] via GitHub
• Re: [I] [Bug]: Unhandled exception in KafkaIO SDF [beam] via GitHub
• Re: [PR] Fix unhandled exception in KafkaIO SDF (#37449) [beam] via GitHub
• Re: [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] via GitHub
  • [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump uuid from 8.3.2 to 14.0.0 in /sdks/typescript [beam] via GitHub
• Re: [PR] Remove incorrect type hint. [beam] via GitHub
  • Re: [PR] Remove incorrect type hint. [beam] via GitHub
  • Re: [PR] Remove incorrect type hint. [beam] via GitHub
  • Re: [PR] Remove incorrect type hint. [beam] via GitHub
  • Re: [PR] Remove incorrect type hint. [beam] via GitHub
  • Re: [PR] Remove incorrect type hint. [beam] via GitHub
  • Re: [PR] Remove incorrect type hint. [beam] via GitHub
• Re: [PR] fix: correct typo "occured" to "occurred" in data_sampler.py [beam] via GitHub
• Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] via GitHub
  • Re: [PR] Provide a robust Go SDK Spanner IO for Change Streams. See CHANGESTRE… [beam] via GitHub
• Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
  • Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
  • Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
  • Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
  • Re: [PR] Add foundational API for Unbounded Sources in Python SDK [beam] via GitHub
• Re: [PR] Omit state commits in stateful Dofn [beam] via GitHub
• Re: [PR] Add Python example for slowly updating global window side input pattern [beam] via GitHub
  • Re: [PR] Add Python example for slowly updating global window side input pattern [beam] via GitHub
• Re: [PR] [python][io] Add native GenerateSequence bounded PTransform (#18088) [beam] via GitHub
  • Re: [PR] [python][io] Add native GenerateSequence bounded PTransform (#18088) [beam] via GitHub
• Re: [PR] [Go SDK] Rewrite dot runner to generate DOT from portable pipeline proto [beam] via GitHub
• Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
  • Re: [PR] Report source lineage from HadoopFormatIO [beam] via GitHub
• Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior [beam] via GitHub
  • Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior [beam] via GitHub
• Re: [PR] [Java]:Add support for portable timestamp logical types (micros_instant, nanos_instant) in BeamCalcRel [beam] via GitHub
• Re: [PR] Update triggering frequency documentation for Storage API methods [beam] via GitHub
  • Re: [PR] Update triggering frequency documentation for Storage API methods [beam] via GitHub
• Re: [PR] Add primitive read translators [beam] via GitHub
• Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] via GitHub
  • Re: [PR] Use Topological ordering during ProcessBundle in SDKHarness [beam] via GitHub
• Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
  • Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
• Re: [I] [Feature Request]: Creation of BigQuery clone table via BigQueryIO [beam] via GitHub
  • Re: [I] [Feature Request]: Creation of BigQuery clone table via BigQueryIO [beam] via GitHub
  • Re: [I] [Feature Request]: Creation of BigQuery clone table via BigQueryIO [beam] via GitHub
• Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
  • Re: [PR] [Gemini] Migrate all remaining uses of typing types with built-in equivalents [beam] via GitHub
• Re: [PR] Bump cloud.google.com/go/bigquery from 1.72.0 to 1.73.1 in /sdks [beam] via GitHub
• Re: [PR] Bump google.golang.org/api from 0.257.0 to 0.269.0 in /sdks [beam] via GitHub
• Re: [PR] Fix Playground CI Nightly job [beam] via GitHub
  • [PR] Fix Playground CI Nightly job [beam] via GitHub
  • Re: [PR] Fix Playground CI Nightly job [beam] via GitHub
  • Re: [PR] Fix Playground CI Nightly job [beam] via GitHub
  • Re: [PR] Fix Playground CI Nightly job [beam] via GitHub
• [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
  • Re: [PR] Fix SystemError in _DeferredCall.get() under GC pressure [beam] via GitHub
• [PR] Update republish_released_docker_containers.yml to 2.73.0 [beam] via GitHub
  • Re: [PR] Update republish_released_docker_containers.yml to 2.73.0 [beam] via GitHub
  • Re: [PR] Update republish_released_docker_containers.yml to 2.73.0 [beam] via GitHub
• [PR] Bump to Beam 2.73.0 [beam-starter-java] via GitHub
  • Re: [PR] Bump to Beam 2.73.0 [beam-starter-java] via GitHub
• Re: [PR] Deflake PreCommit Java watchForNewFiles [beam] via GitHub
• Re: [I] Requesting invitation to ASF Slack Workspace [beam] via GitHub
• Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior (fixes #37445) [beam] via GitHub
  • Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior (fixes #37445) [beam] via GitHub
  • Re: [PR] Make GCS filesystem lookup lazy to match S3 behavior (fixes #37445) [beam] via GitHub
• Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
  • Re: [PR] datastore: Same key in mutation batch [beam] via GitHub
• [PR] Mark dynamically generated ml_preprocessing test as no_xdist for prec… [beam] via GitHub
  • Re: [PR] Mark dynamically generated ml_preprocessing test as no_xdist for prec… [beam] via GitHub
  • Re: [PR] Mark dynamically generated ml_preprocessing test as no_xdist for prec… [beam] via GitHub
  • Re: [PR] Mark dynamically generated ml_preprocessing test as no_xdist for prec… [beam] via GitHub
  • Re: [PR] Mark dynamically generated ml_preprocessing test as no_xdist for prec… [beam] via GitHub
• Re: [PR] Revert "remove processContext usage across examples (java and kotlin)" [beam] via GitHub
• Re: [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] via GitHub
  • Re: [I] The PostCommit Python Xlang Gcp Direct job is flaky [beam] via GitHub
• Re: [PR] Fix PostCommit Python Xlang Gcp Direct job [beam] via GitHub
• [PR] Update jinja2 requirement from <4.0.0,>=2.7.1 to >=3.0.3,<4.0.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update jinja2 requirement from <4.0.0,>=2.7.1 to >=3.0.3,<4.0.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update jinja2 requirement from <4.0.0,>=2.7.1 to >=3.0.3,<4.0.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update jinja2 requirement from <4.0.0,>=2.7.1 to >=3.0.3,<4.0.0 in /sdks/python [beam] via GitHub
• [PR] Update numpy requirement from <2.5.0,>=1.14.3 to >=2.1.3,<2.5.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update numpy requirement from <2.5.0,>=1.14.3 to >=2.1.3,<2.5.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update numpy requirement from <2.5.0,>=1.14.3 to >=2.1.3,<2.5.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update numpy requirement from <2.5.0,>=1.14.3 to >=2.1.3,<2.5.0 in /sdks/python [beam] via GitHub
• [PR] Update pyyaml requirement from <7.0.0,>=3.12 to >=5.4.1,<7.0.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update pyyaml requirement from <7.0.0,>=3.12 to >=5.4.1,<7.0.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update pyyaml requirement from <7.0.0,>=3.12 to >=5.4.1,<7.0.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update pyyaml requirement from <7.0.0,>=3.12 to >=5.4.1,<7.0.0 in /sdks/python [beam] via GitHub
• [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps pipeline options for the Java and GO SDKs and update Go client libraries [beam] via GitHub
• [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
  • Re: [PR] Support staging Python packages given via a URL [beam] via GitHub
• Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub
  • Re: [PR] Add Staged Artifact validations for RunnerV2 [beam] via GitHub

• Earlier messages
• Later messages