apache / apache/beam

Batch Pub/Sub sink does not set idLabel

Open
#18,023 0 comments 0 reactions 0 assignees View on GitHub
bug gcp good first issue io java P3
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
2d 2h
Merged PRs (30d)
205

Description

The transform should generate a unique token (must be stable across retries), and set it on outgoing pubsub messages if an idLabel has been set

Imported from Jira [BEAM-361](https://issues.apache.org/jira/browse/BEAM-361). Original Jira may contain additional context.
Reported by: millsd@google.com.

Contributor guide

Open the contributing guide

Research direction

Locate the Java Batch Pub/Sub sink and inspect how its transform creates outgoing messages and handles retries. Implement the requested stable unique token when idLabel is set, then verify that outgoing messages carry it and that repeated retries preserve the same token.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
data-engineering
Issue type
Bug
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.