apache/beam issues and pull requests

#33670 - Performance Regression or Improvement: pytorch_image_classification_benchmarks-resnet152-GPU-mean_inference_batch_latency_micro_secs:mean_inference_batch_latency_micro_secs

Issue - State: closed - Opened by github-actions[bot] about 1 month ago - 2 comments
Labels: awaiting triage, perf-alert

#33669 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33668 - pin sentence-transformers==3.3.1

Pull Request - State: closed - Opened by liferoad about 1 month ago - 1 comment
Labels: python, Next Action: Reviewers

#33667 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33666 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33665 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33664 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33663 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33662 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33661 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33660 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33659 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33658 - Updated the python dependencies (targeted for Beam 2.63.0)

Pull Request - State: closed - Opened by liferoad about 1 month ago - 6 comments
Labels: python, docker, Next Action: Reviewers

#33657 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33656 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33655 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33654 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33653 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33652 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33651 - [GoSDK + Prism] Support Process env execution.

Pull Request - State: closed - Opened by lostluck about 1 month ago - 2 comments
Labels: go, runners, prism

#33650 - [Task]: Modernize Protos to Editions, with minimal SDK code changes due to code generation.

Issue - State: open - Opened by lostluck about 1 month ago
Labels: python, java, go, typescript, P3, task, awaiting triage

#33649 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33648 - Add support for Iceberg table identifiers with special characters

Pull Request - State: open - Opened by regadas about 1 month ago - 7 comments
Labels: java, build, io, Next Action: Reviewers

#33647 - Support relative paths for yaml includes and resources.

Pull Request - State: closed - Opened by robertwb about 1 month ago - 2 comments
Labels: python, yaml

#33646 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: open - Opened by github-actions[bot] about 1 month ago - 2 comments
Labels: P1, bug, flaky_test, workflow_id: 69772389

#33645 - Use local loopback worker from Python expansion services.

Pull Request - State: closed - Opened by robertwb about 1 month ago - 3 comments
Labels: python, yaml

#33644 - [Task]: Build a cleaner for assets in the GCP test environment

Issue - State: open - Opened by pabloem about 1 month ago - 3 comments
Labels: infra, task, gsoc, P2

#33643 - [Task]: Update google-cloud-spanner to 6.85.0

Issue - State: closed - Opened by jrmccluskey about 1 month ago - 1 comment
Labels: java, task, P2, awaiting triage

#33642 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: closed - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33641 - Added the numpy issues to CHANGES.md

Pull Request - State: open - Opened by liferoad about 1 month ago - 3 comments
Labels: Next Action: Reviewers

#33640 - The PostCommit Java Examples Dataflow V2 job is flaky

Issue - State: open - Opened by github-actions[bot] about 1 month ago
Labels: P1, bug, flaky_test

#33639 - [Bug]: Update Beam containers to numpy 2.x

Issue - State: closed - Opened by tvalentyn about 1 month ago - 3 comments
Labels: python, P1, bug

#33638 - [release-2.62.0] Roll forward the dependency upgrade commit.

Pull Request - State: closed - Opened by tvalentyn about 1 month ago - 4 comments
Labels: python, docker

#33637 - Fix distroless workflows

Pull Request - State: closed - Opened by damondouglas about 1 month ago - 1 comment
Labels: python, build, Next Action: Reviewers

#33636 - [Bug]: The output reports success when Dataflow template creation is not successful

Issue - State: closed - Opened by baeminbo about 1 month ago - 2 comments
Labels: java, dataflow, bug, P2, awaiting triage

#33635 - Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.73.0 to 1.73.1 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies, Next Action: Reviewers

#33634 - Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.50 to 1.17.51 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies, Next Action: Reviewers

#33633 - [Feature Request]: Support ProcessingTime Timer in Spark Runner

Issue - State: open - Opened by twosom about 1 month ago - 1 comment
Labels: java, spark, new feature, P2

#33632 - [Feature Request]: Dynamic partition key in WriteToKinesis

Issue - State: open - Opened by Nakachi-S about 1 month ago
Labels: python, java, dataflow, new feature, P2, awaiting triage

#33631 - Update release-guide.md

Pull Request - State: open - Opened by liferoad about 1 month ago - 1 comment
Labels: Next Action: Reviewers

#33630 - Expand documentation about YAML providers.

Pull Request - State: closed - Opened by robertwb about 1 month ago - 1 comment
Labels: website, Next Action: Reviewers

#33629 - Improve global sequence processing in Java SDK's "ordered" extension

Pull Request - State: closed - Opened by slilichenko about 1 month ago - 3 comments
Labels: java, extensions, Next Action: Reviewers

#33628 - Revert "Migrate Beam Go to use the new Opaque Protocol Buffers"

Pull Request - State: closed - Opened by lostluck about 1 month ago - 3 comments
Labels: python, java, go, examples, docker, io, runners, dataflow, gcp, typescript, prism

#33627 - [DO NOT MERGE] only pin down numpy==2.2.1 and pandas==2.2.3 for 2.62.0

Pull Request - State: closed - Opened by liferoad about 1 month ago - 8 comments
Labels: python, docker, Next Action: Reviewers

#33626 - make Coder.getEncodedElementByteSize public to allow performance improvements in higher level coders

Pull Request - State: closed - Opened by stankiewicz about 1 month ago - 4 comments
Labels: java, io, extensions, runners, dataflow, gcp, fn-execution, protobuf, sketching, Next Action: Reviewers

#33625 - [Iceberg] Add BQMS test that validates using a BQ query

Pull Request - State: closed - Opened by ahmedabu98 about 1 month ago - 4 comments
Labels: java, build, io, Next Action: Reviewers

#33624 - [Bug]: Issue with GroupIntoBatches Between Two Aggregations

Issue - State: open - Opened by yelianevich about 1 month ago - 1 comment
Labels: java, flink, bug, P2, awaiting triage

#33623 - [Bug][Prism]: Colab cannot run PrismRunner multiple times

Issue - State: open - Opened by liferoad about 1 month ago - 2 comments
Labels: python, go, bug, P2

#33620 - [Bug]: StateBackedIterable serializes elements size for every element when ComposedCombine is used

Issue - State: closed - Opened by stankiewicz about 1 month ago - 1 comment
Labels: java, dataflow, bug, P2, awaiting triage

#33619 - Bump github.com/aws/aws-sdk-go-v2/credentials from 1.17.52 to 1.17.53 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: go, dependencies

#33618 - Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.72.3 to 1.73.0 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: go, dependencies

#33617 - Bump github.com/aws/aws-sdk-go-v2/config from 1.28.11 to 1.29.0 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies, Next Action: Reviewers

#33616 - Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.17.49 to 1.17.50 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: go, dependencies, Next Action: Reviewers

#33615 - Bump github.com/aws/aws-sdk-go-v2 from 1.32.8 to 1.33.0 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies, Next Action: Reviewers

#33614 - Remove type coercion of `FinalizeWrite` in iobase.py

Pull Request - State: open - Opened by liaopeiyuan about 1 month ago - 6 comments
Labels: python, io, Next Action: Reviewers, slow-review

#33613 - Don't multiply tests on LogForTesting providers.

Pull Request - State: closed - Opened by robertwb about 1 month ago - 1 comment
Labels: python, Next Action: Reviewers, yaml

#33612 - Support sharding in WriteToFiles (tested for to_csv)

Pull Request - State: open - Opened by langner about 1 month ago - 5 comments
Labels: python, io, Next Action: Author

#33611 - sdks/python: enable recursive deletion for GCSFileSystem Paths

Pull Request - State: open - Opened by mohamedawnallah about 1 month ago - 10 comments
Labels: python, io, gcp, Next Action: Reviewers

#33610 - Handle missing tables more gracefully.

Pull Request - State: open - Opened by bmrosen about 1 month ago - 1 comment
Labels: python, io, gcp

#33609 - [Go SDK] Update min Go version to 1.22.10 and deps.

Pull Request - State: closed - Opened by lostluck about 1 month ago - 2 comments
Labels: go

#33608 - [Feature Request]: managed IO connector for Apache Iceberg to offer Configurable Write Options for Target Table

Issue - State: open - Opened by eder001 about 1 month ago
Labels: io, new feature, P2, awaiting triage

#33607 - Add langchain dep to ML tests.

Pull Request - State: closed - Opened by claudevdm about 1 month ago - 3 comments
Labels: python

#33606 - [flink] FlinkRunner initializes the same split twice (#31313)

Pull Request - State: closed - Opened by je-ik about 1 month ago - 5 comments
Labels: build, runners, flink, Next Action: Reviewers

#33605 - sdks/python: replace `applymap` with `map` in `DataFrame`

Pull Request - State: closed - Opened by mohamedawnallah about 1 month ago - 5 comments
Labels: python, runners, Next Action: Reviewers

#33604 - Bump golang.org/x/sys from 0.28.0 to 0.29.0 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies

#33603 - Bump github.com/testcontainers/testcontainers-go from 0.33.0 to 0.35.0 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies

#33602 - Bump github.com/aws/aws-sdk-go-v2 from 1.32.7 to 1.32.8 in /sdks

Pull Request - State: closed - Opened by dependabot[bot] about 1 month ago - 2 comments
Labels: go, dependencies

#33601 - Bump com.gradle.develocity from 3.18.2 to 3.19

Pull Request - State: open - Opened by dependabot[bot] about 1 month ago - 4 comments
Labels: build, dependencies, Next Action: Reviewers

#33600 - Bump com.diffplug.spotless from 5.6.1 to 7.0.2

Pull Request - State: open - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: build, dependencies

#33599 - Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 7.0.2

Pull Request - State: open - Opened by dependabot[bot] about 1 month ago - 1 comment
Labels: build, dependencies

#33598 - DatastoreV1.Write, DeleteEntity and DeleteKey can optionally return PCollection

Pull Request - State: closed - Opened by bitnahian about 1 month ago - 7 comments
Labels: java, io, gcp, Next Action: Reviewers

#33597 - [Dataflow Streaming Appliance] Fix per key commit size validation

Pull Request - State: closed - Opened by arunpandianp about 1 month ago - 5 comments
Labels: runners, dataflow

#33596 - Offset-based deduplication for Kafka source.

Pull Request - State: open - Opened by tomstepp about 1 month ago - 14 comments
Labels: java, io, kafka

#33595 - [Feature Request]: Add the ability to cancel timers in methods annotated with @onWindowExpiration

Issue - State: open - Opened by slilichenko about 1 month ago
Labels: java, new feature, P2, awaiting triage

#33594 - Publish build scans to develocity.apache.org

Pull Request - State: closed - Opened by clayburn about 1 month ago - 1 comment
Labels: Next Action: Reviewers

#33593 - Add Vertex embeddings to RAG package.

Pull Request - State: closed - Opened by claudevdm about 1 month ago - 2 comments
Labels: python

#33592 - [IcebergIO] cleanups, improvements, and test tweaks

Pull Request - State: closed - Opened by ahmedabu98 about 1 month ago - 3 comments
Labels: java, build, io, Next Action: Reviewers, slow-review

#33591 - Add offset-based deduplication to Unbounded Source and Dataflow Runner.

Pull Request - State: closed - Opened by tomstepp about 1 month ago - 3 comments
Labels: java, runners, dataflow

#33590 - Remove yapf version specification in tox.ini

Pull Request - State: closed - Opened by jrmccluskey about 1 month ago
Labels: python

#33589 - Update CHANGES with some Prism and Go SDK notes.

Pull Request - State: closed - Opened by lostluck about 1 month ago - 2 comments

#33588 - [Bug]: [Dataflow Streaming Appliance] Key commits > 180MB are failing with KeyCommitTooLargeException with beam 2.60.0+

Issue - State: closed - Opened by arunpandianp about 1 month ago - 2 comments
Labels: dataflow, bug, P2

GitHub / apache/beam issues and pull requests