[Bug]: Teardown method is never called - Githubissues

apache / beam

Apache Beam is a unified programming model for Batch and Streaming data processing.

https://beam.apache.org/

Apache License 2.0

7.76k stars 4.21k forks source link

[Bug]: Teardown method is never called #31381

Open boolangery opened 3 months ago

boolangery commented 3 months ago

What happened?

Teardown is never called when running locally with prism or on Dataflow.

Tested signature: Teardown(ctx context.Context) error

Issue Priority

Priority: 3 (minor)

Issue Components

[ ] Component: Python SDK
[ ] Component: Java SDK
[X] Component: Go SDK
[ ] Component: Typescript SDK
[ ] Component: IO connector
[ ] Component: Beam YAML
[ ] Component: Beam examples
[ ] Component: Beam playground
[ ] Component: Beam katas
[ ] Component: Website
[ ] Component: Spark Runner
[ ] Component: Flink Runner
[ ] Component: Samza Runner
[ ] Component: Twister2 Runner
[ ] Component: Hazelcast Jet Runner
[ ] Component: Google Cloud Dataflow Runner

Abacn commented 1 month ago

Same happens on Python SDK run on Dataflow. Python direct runner has teardown called.

Abacn commented 1 month ago

The same for Dataflow Java (runner v1/v2): #18592