apache/beam

Check immutability violations in Dataflow Runner (as an option)

Open

#19 400 ouverte le 3 juin 2022

Voir sur GitHub
 (0 commentaires) (0 réactions) (0 assignés)Java (4 097 forks)batch import
P3coregood first issuenew featurepython

Métriques du dépôt

Stars
 (7 313 stars)
Métriques de merge PR
 (Merge moyen 6j) (243 PRs mergées en 30 j)

Description

Users are going to mutate inputs and outputs of DoFn inappropriately. We should help their tests fail to catch such mistakes. (Similar to the DirectPipelineRunner in Java SDK) This should be offered as an option and worked based on sampling because of the cost of these checks.

Imported from Jira BEAM-7395. Original Jira may contain additional context. Reported by: altay.

Guide contributeur