apache/beam

Batch Pub/Sub sink does not set idLabel

Open

#18,023 opened on Jun 3, 2022

 (0 comments) (0 reactions) (0 assignees)Java (4,097 forks)batch import
P3buggcpgood first issueiojava

Repository metrics

Stars
 (7,313 stars)
PR merge metrics
 (PR metrics pending)

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. Original Jira may contain additional context. Reported by: millsd@google.com.

Contributor guide