github  

Messages by Thread

• [PR] add auto gemini review comment workflow [beam] via GitHub
  • Re: [PR] add auto gemini review comment workflow [beam] via GitHub
  • Re: [PR] add auto gemini review comment workflow [beam] via GitHub
  • Re: [PR] add auto gemini review comment workflow [beam] via GitHub
  • Re: [PR] add auto gemini review comment workflow [beam] via GitHub
  • Re: [PR] add auto gemini review comment workflow [beam] via GitHub
  • Re: [PR] add auto gemini review comment workflow [beam] via GitHub
• [PR] [ValueKind] Add to model [beam] via GitHub
  • Re: [PR] [ValueKind] Add to model [beam] via GitHub
  • Re: [PR] [ValueKind] Add to model [beam] via GitHub
  • Re: [PR] [ValueKind] Add to model [beam] via GitHub
• [PR] Rename run_pylint.sh [beam] via GitHub
  • Re: [PR] Rename run_pylint.sh [beam] via GitHub
  • Re: [PR] Rename run_pylint.sh [beam] via GitHub
  • Re: [PR] Rename run_pylint.sh [beam] via GitHub
• [PR] Consolidate linting and type checking configs into pyproject.toml [beam] via GitHub
  • Re: [PR] Consolidate linting and type checking configs into pyproject.toml [beam] via GitHub
  • Re: [PR] Consolidate linting and type checking configs into pyproject.toml [beam] via GitHub
  • Re: [PR] Consolidate linting and type checking configs into pyproject.toml [beam] via GitHub
  • Re: [PR] Consolidate linting and type checking configs into pyproject.toml [beam] via GitHub
• [I] [Feature Request]: Expose setMaxRequestCallbackWaitTime in BigQuery storage write [beam] via GitHub
• [PR] Bump Docker PreCommit timeout, address errant setuptools warning [beam] via GitHub
  • Re: [PR] Bump Docker PreCommit timeout, address errant setuptools warning [beam] via GitHub
  • Re: [PR] Bump Docker PreCommit timeout, address errant setuptools warning [beam] via GitHub
  • Re: [PR] Bump Docker PreCommit timeout, address errant setuptools warning [beam] via GitHub
• [PR] Improve coder inference in WithKeys to reduce mismatch risks [beam] via GitHub
  • Re: [PR] Improve coder inference in WithKeys to reduce mismatch risks [beam] via GitHub
  • Re: [PR] Improve coder inference in WithKeys to reduce mismatch risks [beam] via GitHub
• [PR] [Experimental] Use uv over pip in Python Dockerfiles [beam] via GitHub
  • Re: [PR] [Experimental] Use uv over pip in Python Dockerfiles [beam] via GitHub
  • Re: [PR] [Experimental] Use uv over pip in Python Dockerfiles [beam] via GitHub
  • Re: [PR] [Experimental] Use uv over pip in Python Dockerfiles [beam] via GitHub
• Re: [I] JsonToRow can catch errors in downstream transforms [beam] via GitHub
• Re: [I] Code coverage numbers are not accurate [beam] via GitHub
• Re: [I] ValueState could use an initial/default value [beam] via GitHub
• Re: [I] In WithKeys, get coder for key more safely. [beam] via GitHub
• Re: [I] [Task]: Error prone issues & Code Clarity Bugs [beam] via GitHub
• Re: [PR] [WIP] Add vllm Dynamo support [beam] via GitHub
• [PR] Fix PostCommit Python Arm job [beam] via GitHub
  • Re: [PR] Fix PostCommit Python Arm job [beam] via GitHub
  • Re: [PR] Fix PostCommit Python Arm job [beam] via GitHub
• Re: [I] The PreCommit Python job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Python job is flaky [beam] via GitHub
• [PR] Update build requirement from <2,>=1.0 to >=1.4.4,<2 in /sdks/python [beam] via GitHub
  • Re: [PR] Update build requirement from <2,>=1.0 to >=1.4.4,<2 in /sdks/python [beam] via GitHub
  • Re: [PR] Update build requirement from <2,>=1.0 to >=1.4.4,<2 in /sdks/python [beam] via GitHub
  • Re: [PR] Update build requirement from <2,>=1.0 to >=1.4.4,<2 in /sdks/python [beam] via GitHub
  • Re: [PR] Update build requirement from <2,>=1.0 to >=1.4.4,<2 in /sdks/python [beam] via GitHub
• [PR] Update wheel requirement from >=0.36.0 to >=0.47.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update wheel requirement from >=0.36.0 to >=0.47.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update wheel requirement from >=0.36.0 to >=0.47.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update wheel requirement from >=0.36.0 to >=0.47.0 in /sdks/python [beam] via GitHub
  • Re: [PR] Update wheel requirement from >=0.36.0 to >=0.47.0 in /sdks/python [beam] via GitHub
• [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
  • Re: [PR] update beam python container [beam] via GitHub
• [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: [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: [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] 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] Use trigger state to know if a window is new and optimize reads [beam] via GitHub
• Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
  • Re: [PR] Add DiskProvisionedIops/ThroughputMibps options and update Go client libraries [beam] via GitHub
• [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
  • Re: [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
  • Re: [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
  • Re: [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
  • Re: [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
  • Re: [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
  • Re: [PR] Fix LineagePluginTest on runners other than Direct runner [beam] via GitHub
• [PR] Revert #36781 Implement pluggable Lineage in Java SDK [beam] via GitHub
  • Re: [PR] Revert #36781 Implement pluggable Lineage in Java SDK [beam] via GitHub
  • Re: [PR] Revert #36781 Implement pluggable Lineage in Java SDK [beam] via GitHub
  • Re: [PR] Revert #36781 Implement pluggable Lineage in Java SDK [beam] via GitHub
• Re: [I] [Task]: SamzaInternalTimerFactory needs limit the processing time timer buffer [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests.testWindowFnPostMerging [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidRecord [beam] via GitHub
• Re: [I] [Task][Dependency]: Upgrade org.apache.samza to 1.7 [beam] via GitHub
• Re: [I] [Task] Default transform metrics like throughput, latency & watermark progress for Beam Samza Runner [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidLengthMask [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testParDoShiftTimestampInvalidZeroAllowed [beam] via GitHub
• Re: [I] [Bug]: Samza AsyncDoFnRunnerTest.testSimplePipeline is flaky (now disabled) [beam] via GitHub
• Re: [I] Samza Portable Runner: Support Merging Custom Window Fns [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.DeduplicateTest.testEventTime [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testParDoShiftTimestampInvalid [beam] via GitHub
• Re: [I] Support Post Job metrics in Portable Samza Runner [beam] via GitHub
• Re: [I] Add Runner API pipeline and jobInfo in SamzaRunner configs [beam] via GitHub
• Re: [I] Clear ready timers before shutdown [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.ViewTest.testMapSideInputWithNullValuesCatchesDuplicates [beam] via GitHub
• Re: [I] [Task]: Support synchronized processing time timer [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidDataMask [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWritingToUndeclaredTag [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.io.TextIOReadTest$CompressedReadTest.testCompressedReadWithoutExtension [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoReadingFromUnknownSideInput [beam] via GitHub
• Re: [I] Enable org.apache.beam.sdk.io.WriteFilesTest.testWithRunnerDeterminedShardingUnbounded [beam] via GitHub
• Re: [I] Samza runner failing PipelineTest.testEmptyPipeline [beam] via GitHub
• Re: [I] [Task]: Enable NeedsRunner Tests in Samza Runner [beam] via GitHub
• Re: [I] Samza runner failing PCollectionCustomCoderTest [beam] via GitHub
• Re: [I] Samza portable Runner: Support SDF [beam] via GitHub
• Re: [I] Samza Portable Runner: Support Bundle Finalization [beam] via GitHub
• Re: [I] Samza runner failing ViewTest [beam] via GitHub
• Re: [I] Samza Runner: Support Distribution Metric [beam] via GitHub
• Re: [I] Samza runner failing GroupIntoBatchesTest [beam] via GitHub
• Re: [I] Samza runner failing AvroIOTest [beam] via GitHub
• Re: [I] Samza ValidatesRunner Reshuffle tests on Go SDK [beam] via GitHub
• Re: [I] Samza runner failing WithTimestampsTest [beam] via GitHub
• Re: [I] Samza runner failing FileIOTest [beam] via GitHub
• Re: [I] Samza runner failing MapElementsTest.testMapSimpleFunction [beam] via GitHub
• Re: [I] Enable ValidatesPortableRunner tests in Samza Runner [beam] via GitHub
• Re: [I] Support transcoding for Flatten in Samza Runner [beam] via GitHub
• Re: [I] Flink and Samza pipeline options are incompatible [beam] via GitHub
• Re: [I] Support Timer output timestamp in Samza Runner [beam] via GitHub
• Re: [I] Enable UsesAttemptedMetrics ValidatesPortableRunner tests in Samza Runner [beam] via GitHub
• Re: [I] Samza runner fails UsesStrictTimerOrdering category tests [beam] via GitHub
• Re: [I] support Splittable DoFn in samza runner [beam] via GitHub
• Re: [I] create python example for samza portable runner [beam] via GitHub
• Re: [I] Support @RequiresStableInput on Samza runner [beam] via GitHub
• [PR] Update changes [beam] via GitHub
  • Re: [PR] Update changes [beam] via GitHub
  • Re: [PR] Update changes [beam] via GitHub
  • Re: [PR] Update changes [beam] via GitHub
  • Re: [PR] Update changes [beam] via GitHub
  • Re: [PR] Update changes [beam] via GitHub
  • Re: [PR] Update changes [beam] via GitHub
• [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
  • Re: [PR] Fix PerformanceTests HadoopFormat job [beam] via GitHub
• Re: [I] [Failing Test]: PostCommitJava Sickbay perma-red [beam] via GitHub
  • Re: [I] [Failing Test]: PostCommitJava Sickbay perma-red [beam] via GitHub
• Re: [I] [Bug]: Need permission to add exceptions to CSP [beam] via GitHub
  • Re: [I] [Bug]: Need permission to add exceptions to CSP [beam] via GitHub
• Re: [I] [Bug] Beam errors out when using PortableRunner (Flink Runner) – `Cannot run program "docker"` [beam] via GitHub
• Re: [I] [Task]: Tracking cloudpickle issues [beam] via GitHub
  • Re: [I] [Task]: Tracking cloudpickle issues [beam] via GitHub
• Re: [I] [Task]: Improve Windmill GRPC Streams [beam] via GitHub
  • Re: [I] [Task]: Improve Windmill GRPC Streams [beam] via GitHub
• [PR] Pin transformers/tokenizers for ML tests [beam] via GitHub
  • Re: [PR] Pin transformers/tokenizers for ML tests [beam] via GitHub
  • Re: [PR] Pin transformers/tokenizers for ML tests [beam] via GitHub
• [PR] Fix PreCommit Java Dataflow non-portable runner [beam] via GitHub
  • Re: [PR] Fix PreCommit Java Dataflow non-portable runner [beam] via GitHub
  • Re: [PR] Fix PreCommit Java Dataflow non-portable runner [beam] via GitHub
  • Re: [PR] Fix PreCommit Java Dataflow non-portable runner [beam] via GitHub
  • Re: [PR] Fix PreCommit Java Dataflow non-portable runner [beam] via GitHub
  • Re: [PR] Fix PreCommit Java Dataflow non-portable runner [beam] via GitHub
• [PR] Fix ML presubmits. [beam] via GitHub
  • Re: [PR] Fix ML presubmits. [beam] via GitHub
  • Re: [PR] Fix ML presubmits. [beam] via GitHub
  • Re: [PR] Fix ML presubmits. [beam] via GitHub
• Re: [I] [Prism] Drain behavior [beam] via GitHub
  • Re: [I] [Prism] Drain behavior [beam] via GitHub
• Re: [I] [Failing Test]: BigQueryIO and BigTableIO integration test failed in ValidateRunner_GoUsingJava [beam] via GitHub
• Re: [PR] SolaceIO - add ack deadline [beam] via GitHub
• [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
  • Re: [I] The Playground CI Nightly job is flaky [beam] via GitHub
• [PR] WIP Add custom window support in Go SDK [beam] via GitHub
  • Re: [PR] WIP Add custom window support in Go SDK [beam] via GitHub

• Earlier messages
• Later messages