github  

Messages by Thread

• [PR] Added a descriptive message tell about status badges [beam] via GitHub
  • Re: [PR] Added a descriptive message tell about status badges [beam] via GitHub
  • Re: [PR] Added a descriptive message tell about status badges [beam] via GitHub
• [PR] improve Maven badge readability in README [beam] via GitHub
  • Re: [PR] improve Maven badge readability in README [beam] via GitHub
  • Re: [PR] improve Maven badge readability in README [beam] via GitHub
• [PR] Add Quick Start section to README [beam] via GitHub
  • Re: [PR] Add Quick Start section to README [beam] via GitHub
  • Re: [PR] Add Quick Start section to README [beam] via GitHub
• [PR] Improved comments and readability in minimal_wordcount example [beam] via GitHub
  • Re: [PR] Improved comments and readability in minimal_wordcount example [beam] via GitHub
  • Re: [PR] Improved comments and readability in minimal_wordcount example [beam] via GitHub
• [I] The PreCommit Java GCP IO Direct job is flaky [beam] via GitHub
  • Re: [I] The PreCommit Java GCP IO Direct job is flaky [beam] via GitHub
• [PR] Add hashes for staged files and relevant validations in boot [beam] via GitHub
  • Re: [PR] Add hashes for staged files and relevant validations in boot [beam] via GitHub
• [PR] Bump flatted from 3.4.1 to 3.4.2 in /sdks/typescript [beam] via GitHub
  • Re: [PR] Bump flatted from 3.4.1 to 3.4.2 in /sdks/typescript [beam] via GitHub
• [I] [Performance]: Heavy CPU usage by org.github.jamm.MemoryMeter.measureDeep [beam] via GitHub
• [PR] [Java IO] Add ArrowFlight IO connector [beam] via GitHub
  • Re: [PR] [Java IO] Add ArrowFlight IO connector [beam] via GitHub
  • Re: [PR] [Java IO] Add ArrowFlight IO connector [beam] via GitHub
• [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
  • Re: [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
  • Re: [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
  • Re: [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
  • Re: [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
  • Re: [PR] [Website] Add missing I/O connectors to built-in connectors table [beam] via GitHub
• [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
  • Re: [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
  • Re: [PR] [ErrorProne] remove voidUsed check [beam] via GitHub
• [PR] Fix #37894: Update yaml doc for composite transform changes [beam] via GitHub
  • Re: [PR] Fix #37894: Update yaml doc for composite transform changes [beam] via GitHub
  • Re: [PR] Fix #37894: Update yaml doc for composite transform changes [beam] via GitHub
• Re: [I] [Bug]: The submission_environment_dependencies.txt file does not get staged when running with Flink runner on Dataproc [beam] via GitHub
• Re: [I] [Task]: Ensure the effective communications during the Beam 3.0.0 development process [beam] via GitHub
• Re: [I] [Disabled Test]: :runners:spark:3:test ResumeFromCheckpointStreamingTest testWithResume is disabled due to flake rate [beam] via GitHub
• Re: [I] [Bug]: Do not expose logging apis in beam/log [beam] via GitHub
• [PR] GCS client library migration in Java SDK - part 3 [beam] via GitHub
  • Re: [PR] GCS client library migration in Java SDK - part 3 [beam] via GitHub
  • Re: [PR] GCS client library migration in Java SDK - part 3 [beam] via GitHub
• [PR] Allow sliding windows + combine with hot key fanout [beam] via GitHub
  • Re: [PR] Allow sliding windows + combine with hot key fanout [beam] via GitHub
  • Re: [PR] Allow sliding windows + combine with hot key fanout [beam] via GitHub
  • Re: [PR] Allow sliding windows + combine with hot key fanout [beam] via GitHub
  • Re: [PR] Allow sliding windows + combine with hot key fanout [beam] via GitHub
• [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
  • Re: [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
  • Re: [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
  • Re: [PR] use sha hash for docker/setup-qemu-action [beam] via GitHub
• [PR] Update Go Version to 1.26.1 [beam] via GitHub
  • Re: [PR] Update Go Version to 1.26.1 [beam] via GitHub
  • Re: [PR] Update Go Version to 1.26.1 [beam] via GitHub
  • Re: [PR] Update Go Version to 1.26.1 [beam] via GitHub
• Re: [I] [Bug]: Incorrect $partition Metadata in Trino for Iceberg Tables Written via IcebergIO.writeRows with Timestamp Partitioning [beam] via GitHub
• Re: [PR] [1/2] sdks/python: sink data with tecton feature store [beam] via GitHub
• Re: [PR] sdks/python: enrich data with tecton feature store [beam] via GitHub
• Re: [I] [Bug]: Prism's handling of side inputs could fail sometime [beam] via GitHub
• Re: [PR] [2/2] notebooks: add OpenAI text embeddings [beam] via GitHub
• [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] via GitHub
  • Re: [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] via GitHub
  • Re: [PR] [Java] Optimize beam pubsub message to serialized pubsub protobuf message [beam] via GitHub
• [PR] Cherrypick #37871 [beam] via GitHub
  • Re: [PR] Cherrypick #37871 [beam] via GitHub
  • Re: [PR] Cherrypick #37871 [beam] via GitHub
• [I] [Task]: update the yaml doc for composite transform changes [beam] via GitHub
• [I] [Task]: Python schema generated types uses schema registry and coder registry [beam] via GitHub
• Re: [I] Introduce SchemaTransform API [beam] via GitHub
  • Re: [I] Introduce SchemaTransform API [beam] via GitHub
• [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
  • Re: [PR] [Runner] Fix SDF checkpoint handling in and upgrade of Samza portable runner (resolves #26126) [beam] via GitHub
• Re: [I] [Bug]: DualInputNestedValueProvider is not able to get Value properly if input is RuntimeValueProvider. [beam] via GitHub
• Re: [I] [Bug]: Cannot read from ssl-enabled cassandra cluster [beam] via GitHub
• [PR] [wip] update deserialization [beam] via GitHub
  • Re: [PR] [wip] update deserialization [beam] via GitHub
  • Re: [PR] [wip] update deserialization [beam] via GitHub
  • Re: [PR] [wip] update deserialization [beam] via GitHub
  • Re: [PR] [wip] update deserialization [beam] via GitHub
• [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
  • Re: [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
  • Re: [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
  • Re: [PR] Attempt to fix flaky GrpcLoggingServiceTest [beam] via GitHub
• [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
  • Re: [PR] Add TableRowMatchers with strict type-aware equality for BigQuery [beam] via GitHub
• [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.78.0 to 1.79.3 in /sdks [beam] via GitHub
• Re: [I] [Feature Request]: allow consistent slog redirects [beam] via GitHub
  • Re: [I] [Feature Request]: allow consistent slog redirects [beam] via GitHub
• [PR] Address no-access pyrefly error [beam] via GitHub
  • Re: [PR] Address no-access pyrefly error [beam] via GitHub
  • Re: [PR] Address no-access pyrefly error [beam] via GitHub
• Re: [I] The Inference Python Benchmarks Dataflow job is flaky [beam] via GitHub
• Re: [I] DebeziumIO cannot connect to cloud Postgres instances [beam] via GitHub
  • Re: [I] DebeziumIO cannot connect to cloud Postgres instances [beam] via GitHub
• Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] via GitHub
  • Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] via GitHub
  • Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] via GitHub
  • Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] via GitHub
  • Re: [PR] Fix flakiness in tests by increasing timeout and changing windowing type [beam] via GitHub
• Re: [I] Matcher(s) for TableRow [beam] via GitHub
• Re: [I] [Task]: Upgrade avro to the latest version after Java 8 is deprecated [beam] via GitHub
• [PR] Fixes broken URLs in example notebooks [beam] via GitHub
  • Re: [PR] Fixes broken URLs in example notebooks [beam] via GitHub
• [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] via GitHub
  • Re: [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] via GitHub
  • Re: [PR] Fix vLLM Gemma benchmark and PyTorch language modeling tests [beam] via GitHub
• [I] [Task]: Getting started - Interactive Overview broken notebook URLs [beam] via GitHub
  • Re: [I] [Task]: Getting started - Interactive Overview broken notebook URLs [beam] via GitHub
• [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
  • Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
  • Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
  • Re: [PR] Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. [beam] via GitHub
• [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
  • Re: [PR] Revert "[Dataflow Streaming] Prevent commit threads from sharing commit streams" [beam] via GitHub
• [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] via GitHub
  • Re: [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] via GitHub
  • Re: [PR] Adds validates runner post commit tests for Java streaming worker on streaming engine [beam] via GitHub
• [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
  • Re: [PR] Fix maven archetype dependency for io-components [beam] via GitHub
• [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
  • Re: [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
  • Re: [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
  • Re: [PR] Add DATE/TIME/DATETIME to portable LogicalTypes.Enum in schema.proto [beam] via GitHub
• [PR] Update Beam website to release 2.72.0 [beam] via GitHub
  • Re: [PR] Update Beam website to release 2.72.0 [beam] via GitHub
• Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] via GitHub
• Re: [I] Globbing asterisk cannot be escaped in file reads. [beam] via GitHub
• Re: [I] [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO` [beam] via GitHub
• [PR] Adding "new metadata" skill [beam] via GitHub
  • Re: [PR] Adding "new metadata" skill [beam] via GitHub
  • Re: [PR] Adding "new metadata" skill [beam] via GitHub
  • Re: [PR] Adding "new metadata" skill [beam] via GitHub
  • Re: [PR] Adding "new metadata" skill [beam] via GitHub
• [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
  • Re: [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
  • Re: [PR] Update managed-io.md for release 2.72.0-RC2 [beam] via GitHub
• Re: [I] [Bug]: Latest version (2.57) version of apache beam java sdk has dependecy on an old version of mongo driver (3.12) [beam] via GitHub
• Re: [I] Handling the restart with apache beam debezium application [beam] via GitHub
• [PR] ci: update build configuration [beam] via GitHub
  • Re: [PR] ci: update build configuration [beam] via GitHub
  • Re: [PR] closed [beam] via GitHub
• Re: [I] [Bug]: Worker logs on Prism Stand-Alone Binary Not Appearing [beam] via GitHub
  • Re: [I] [Bug]: Worker logs on Prism Stand-Alone Binary Not Appearing [beam] via GitHub
• Re: [I] [Feature Request]: Implement IBM MQ Sink Connector for Python SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Implement IBM MQ Sink Connector for Python SDK [beam] via GitHub
• Re: [PR] [OpenTelemetry] Model changes to allow OpenTelemetry context propagation [beam] via GitHub
• [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
  • Re: [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
  • Re: [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
  • Re: [PR] [Java] Improve GroupIntoBatches display data to show batching parameters [beam] via GitHub
• [PR] Cherrypick #37850 [beam] via GitHub
  • Re: [PR] Cherrypick #37850 [beam] via GitHub
  • Re: [PR] Cherrypick #37850 [beam] via GitHub
  • Re: [PR] Cherrypick #37850 [beam] via GitHub
• [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
  • Re: [PR] feat: improve skill scores for apache/beam [beam] via GitHub
• [I] [Bug]: [Python] Union of named fields loss fields after GBK [beam] via GitHub
  • Re: [I] [Bug]: [Python] Union of named fields loss fields after GBK [beam] via GitHub
  • Re: [I] [Bug]: [Python] Union of named fields loss fields after GBK [beam] via GitHub
• [I] [Feature Request]: Support for inferring schemas from Python dataclasses [beam] via GitHub
  • Re: [I] [Feature Request]: Support for inferring schemas from Python dataclasses [beam] via GitHub
• Re: [I] TextIO.write .withWindowedWrites does not work on windows [beam] via GitHub
• Re: [I] [GSOC 25] Enhanced Interactive Pipeline Development Environment for JupyterLab [beam] via GitHub
• Re: [I] [Feature Request]: Implement Native Java Remote Inference [beam] via GitHub
• Re: [PR] Include logger name in FnApiLogRecordHandler log entries [beam] via GitHub
• [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub
  • Re: [PR] Fix #37736: Allow composite transforms to use implicit input chaining [beam] via GitHub

• Earlier messages